Removed channel creation

OlivierCazade · OlivierCazade · commit 8233b92c06b2 · 2022-10-20T11:33:07.000+02:00
diff --git a/pkg/pipeline/write/write_loki.go b/pkg/pipeline/write/write_loki.go
@@ -253,10 +253,6 @@ func NewWriteLoki(opMetrics *operational.Metrics, params config.StageParam) (*Lo
 		}
 	}
 
-	// TODO / FIXME / FIGUREOUT: seems like we have 2 input channels for Loki? (this one, and see also pipeline_builder.go / getStageNode / StageWrite)
-	in := make(chan config.GenericMap, channelSize)
-	opMetrics.CreateInQueueSizeGauge(params.Name+"-2", func() int { return len(in) })
-
 	l := &Loki{
 		lokiConfig:     lokiConfig,
 		apiConfig:      lokiConfigIn,

Original file line number	Diff line number	Diff line change
`@@ -253,10 +253,6 @@ func NewWriteLoki(opMetrics operational.Metrics, params config.StageParam) (Lo`
`253`	`253`	`}`
`254`	`254`	`}`
`255`	`255`
`256`		`- // TODO / FIXME / FIGUREOUT: seems like we have 2 input channels for Loki? (this one, and see also pipeline_builder.go / getStageNode / StageWrite)`
`257`		`- in := make(chan config.GenericMap, channelSize)`
`258`		`- opMetrics.CreateInQueueSizeGauge(params.Name+"-2", func() int { return len(in) })`
`259`		`-`
`260`	`256`	`l := &Loki{`
`261`	`257`	`lokiConfig: lokiConfig,`
`262`	`258`	`apiConfig: lokiConfigIn,`