fix init order

urso · urso · commit 7c0e9d65c9d2 · 2020-04-29T17:27:58.000+02:00
diff --git a/filebeat/beater/filebeat.go b/filebeat/beater/filebeat.go
@@ -237,8 +237,8 @@ func (fb *Filebeat) Run(b *beat.Beat) error {
 		return err
 	}
 
-	fb.pipeline = withPipelineEventCounter(fb.pipeline, wgEvents)
 	fb.pipeline = pipetool.WithDefaultGuarantees(b.Publisher, beat.GuaranteedSend)
+	fb.pipeline = withPipelineEventCounter(fb.pipeline, wgEvents)
 
 	outDone := make(chan struct{}) // outDone closes down all active pipeline connections
 	pipelineConnector := channel.NewOutletFactory(outDone).Create

Original file line number	Diff line number	Diff line change
`@@ -237,8 +237,8 @@ func (fb Filebeat) Run(b beat.Beat) error {`
`237`	`237`	`return err`
`238`	`238`	`}`
`239`	`239`
`240`		`- fb.pipeline = withPipelineEventCounter(fb.pipeline, wgEvents)`
`241`	`240`	`fb.pipeline = pipetool.WithDefaultGuarantees(b.Publisher, beat.GuaranteedSend)`
	`241`	`+ fb.pipeline = withPipelineEventCounter(fb.pipeline, wgEvents)`
`242`	`242`
`243`	`243`	`outDone := make(chan struct{}) // outDone closes down all active pipeline connections`
`244`	`244`	`pipelineConnector := channel.NewOutletFactory(outDone).Create`