Skip to content
This repository has been archived by the owner on Dec 21, 2023. It is now read-only.

Commit

Permalink
added log forwarder
Browse files Browse the repository at this point in the history
Signed-off-by: Florian Bacher <florian.bacher@dynatrace.com>
  • Loading branch information
bacherfl committed May 13, 2022
1 parent 835e8f6 commit 7b410c0
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion approval-service/main.go
Expand Up @@ -60,8 +60,9 @@ func main() {
log.Fatal(err)
}
eventSource := controlplane.NewNATSEventSource(natsConnector)
logForwarder := controlplane.NewLogForwarder(api.LogsV1())

controlPlane := controlplane.New(subscriptionSource, eventSource, nil)
controlPlane := controlplane.New(subscriptionSource, eventSource, logForwarder)

go func() {
keptnapi.RunHealthEndpoint("8080", keptnapi.WithReadinessConditionFunc(func() bool {
Expand Down

0 comments on commit 7b410c0

Please sign in to comment.