linter fixes

elastic · Sep 25, 2024 · bd0cbfd · bd0cbfd
1 parent 38715e2
commit bd0cbfd
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 3 deletions.
diff --git a/x-pack/filebeat/fbreceiver/receiver.go b/x-pack/filebeat/fbreceiver/receiver.go
@@ -19,7 +19,7 @@ type filebeatReceiver struct {
 
 func (fb *filebeatReceiver) Start(ctx context.Context, host component.Host) error {
 	go func() {
-		fb.beater.Run(fb.beat)
+		_ = fb.beater.Run(fb.beat)
 	}()
 	return nil
 }

diff --git a/x-pack/filebeat/fbreceiver/receiver_test.go b/x-pack/filebeat/fbreceiver/receiver_test.go
@@ -54,10 +54,15 @@ func TestNewReceiver(t *testing.T) {
 		countLogs = countLogs + ld.LogRecordCount()
 		return nil
 	})
+	assert.NoError(t, err, "Error creating log consumer")
 
 	r, err := createReceiver(context.Background(), receiverSettings, &config, logConsumer)
 	assert.NoErrorf(t, err, "Error creating receiver. Logs:\n %s", zapLogs.String())
-	r.Start(context.Background(), nil)
+	err = r.Start(context.Background(), nil)
+	assert.NoError(t, err, "Error starting filebeatreceiver")
+
 	assert.Eventuallyf(t, func() bool { return countLogs > 0 }, 60*time.Second, 1*time.Second, "consumed logs didn't increase\nCount: %d\nLogs: %s\n", countLogs, zapLogs.String())
-	r.Shutdown(context.Background())
+
+	err = r.Shutdown(context.Background())
+	assert.NoError(t, err, "Error shutting down filebeatreceiver")
 }