Commit f212507

committed

plugins: Log on the plugin start

Log the fact that a plugin is started. Signed-off-by: Michal Rostecki

1 parent 690b027 commit f212507Copy full SHA for f212507

File tree

-0

lines changed

-0

lines changed

Lines changed: 4 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -3,6 +3,8 @@ package plugins`
`3`	`3`	`import (`
`4`	`4`	`"context"`
`5`	`5`	`"fmt"`
	`6`	`+ "log"`
	`7`	`+`
`6`	`8`	`"github.com/deepfence/PacketStreamer/pkg/config"`
`7`	`9`	`"github.com/deepfence/PacketStreamer/pkg/plugins/kafka"`
`8`	`10`	`"github.com/deepfence/PacketStreamer/pkg/plugins/s3"`
`@@ -18,6 +20,7 @@ func Start(ctx context.Context, config *config.Config) (chan<- string, error) {`
`18`	`20`	`var plugins []chan<- string`
`19`	`21`
`20`	`22`	`if config.Output.Plugins.S3 != nil {`
	`23`	`+ log.Println("Starting S3 plugin")`
`21`	`24`	`s3plugin, err := s3.NewPlugin(ctx, config.Output.Plugins.S3)`
`22`	`25`
`23`	`26`	`if err != nil {`
`@@ -29,6 +32,7 @@ func Start(ctx context.Context, config *config.Config) (chan<- string, error) {`
`29`	`32`	`}`
`30`	`33`
`31`	`34`	`if config.Output.Plugins.Kafka != nil {`
	`35`	`+ log.Println("Starting Kafka plugin")`
`32`	`36`	`kafkaPlugin, err := kafka.NewPlugin(config.Output.Plugins.Kafka)`
`33`	`37`
`34`	`38`	`if err != nil {`

Comments

(0)