Implement PR review suggestions

elastic · Apr 12, 2024 · 45fa1e3 · 45fa1e3
1 parent 81e6cc7
commit 45fa1e3
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/libbeat/publisher/pipeline/pipeline_test.go b/libbeat/publisher/pipeline/pipeline_test.go
@@ -98,8 +98,7 @@ func makeDiscardQueue() queue.Queue {
 			// count is a counter that increments on every published event
 			// it's also the returned Event ID
 			count := uint64(0)
-			var producer *testProducer
-			producer = &testProducer{
+			producer := &testProducer{
 				publish: func(try bool, event interface{}) (queue.EntryID, bool) {
 					count++
 					return queue.EntryID(count), true

diff --git a/x-pack/filebeat/input/entityanalytics/internal/kvstore/input.go b/x-pack/filebeat/input/entityanalytics/internal/kvstore/input.go
@@ -68,7 +68,7 @@ func (n *input) Run(runCtx v2.Context, connector beat.PipelineConnector) (err er
 		EventListener: NewTxACKHandler(),
 	})
 	if err != nil {
-		return fmt.Errorf("could not connect to publishing pipeline: %s", err)
+		return fmt.Errorf("could not connect to publishing pipeline: %w", err)
 	}
 	defer client.Close()