wip

filebeat/input/log/input.go

@@ -138,6 +138,9 @@ func NewInput(
 	//  The outlet generated here is the underlying outlet, only closed
 	//  once all workers have been shut down.
 	//  For state updates and events, separate sub-outlets will be used.
+	// TODO: there is neither ID in the context nor on inputConfig. It seems
+	// there is no ID at all. It's not publishing input metrics anyway. Where
+	// did that chart come from? https://github.com/elastic/beats/issues/42325#issuecomment-2648776284
 	out, err := outlet.Connect(cfg)
 	if err != nil {
 		return nil, err

libbeat/publisher/pipeline/pipeline.go

@@ -189,7 +189,7 @@ func (p *Pipeline) Connect() (beat.Client, error) {
 // ConnectWith create a new Client for publishing events to the pipeline.
 // The client behavior on close and ACK handling can be configured by setting
 // the appropriate fields in the passed ClientConfig.
-// If not set otherwise the defaut publish mode is OutputChooses.
+// If not set otherwise the default publish mode is OutputChooses.
 //
 // It is responsibility of the caller to close the client.
 func (p *Pipeline) ConnectWith(cfg beat.ClientConfig) (beat.Client, error) {