diff --git a/cmd/crowdsec/main.go b/cmd/crowdsec/main.go index d3350db6d..f4f8b2f76 100644 --- a/cmd/crowdsec/main.go +++ b/cmd/crowdsec/main.go @@ -33,6 +33,8 @@ var ( buckets *leaky.Buckets cConfig *csconfig.CrowdSec + OutputRunner *outputs.Output + /*settings*/ lastProcessedItem time.Time /*keep track of last item timestamp in time-machine. it is used to GC buckets when we dump them.*/ ) @@ -224,7 +226,7 @@ func main() { return } - outputRunner, err := outputs.NewOutput(cConfig.OutputConfig, cConfig.Daemonize) + OutputRunner, err := outputs.NewOutput(cConfig.OutputConfig, cConfig.Daemonize) if err != nil { log.Fatalf("output plugins initialization error : %s", err.Error()) } @@ -236,7 +238,7 @@ func main() { "path": cConfig.ConfigFolder + "/api.yaml", "profile": scenariosEnabled, } - if err := outputRunner.InitAPI(apiConfig); err != nil { + if err := OutputRunner.InitAPI(apiConfig); err != nil { log.Fatalf(err.Error()) } } @@ -282,7 +284,7 @@ func main() { for i := 0; i < nbParser; i++ { outputsTomb.Go(func() error { - err := runOutput(inputEventChan, outputEventChan, holders, buckets, *postOverflowCTX, postOverflowNodes, outputProfiles, outputRunner) + err := runOutput(inputEventChan, outputEventChan, holders, buckets, *postOverflowCTX, postOverflowNodes, outputProfiles, OutputRunner) if err != nil { log.Errorf("runPour error : %s", err) return err @@ -301,7 +303,7 @@ func main() { //start reading in the background acquisition.AcquisStartReading(acquisitionCTX, inputLineChan, &acquisTomb) - if err = serve(*outputRunner); err != nil { + if err = serve(*OutputRunner); err != nil { log.Fatalf(err.Error()) }