fix(lint)

Author: lc525

components/kafka/.golangci.yml

@@ -29,7 +29,7 @@ linters:
   enable:
     # Sorted alphabetically.
     - errcheck
-    - exportloopref
+    - copyloopvar
     - gci
     - goimports # Also includes gofmt style formatting
     - gosimple
@@ -51,4 +51,4 @@ linters-settings:
     min-occurrences: 5
   govet:
     disable:
-      - printf
+      - printf

components/tls/.golangci.yml

@@ -29,7 +29,7 @@ linters:
   enable:
     # Sorted alphabetically.
     - errcheck
-    - exportloopref
+    - copyloopvar
     - gci
     - goimports # Also includes gofmt style formatting
     - gosimple
@@ -51,4 +51,4 @@ linters-settings:
     min-occurrences: 5
   govet:
     disable:
-      - printf
+      - printf

hodometer/.golangci.yml

@@ -29,7 +29,7 @@ linters:
   enable:
     # Sorted alphabetically.
     - errcheck
-    - exportloopref
+    - copyloopvar
     - gci
     - goimports # Also includes gofmt style formatting
     - gosimple
@@ -51,4 +51,4 @@ linters-settings:
     min-occurrences: 5
   govet:
     disable:
-      - printf
+      - printf

operator/.golangci.yml

@@ -29,7 +29,7 @@ linters:
   enable:
     # Sorted alphabetically.
     - errcheck
-    - exportloopref
+    - copyloopvar
     - gci
     - goimports # Also includes gofmt style formatting
     - gosimple
@@ -51,4 +51,4 @@ linters-settings:
     min-occurrences: 5
   govet:
     disable:
-      - printf
+      - printf

scheduler/.golangci.yml

@@ -24,7 +24,7 @@ linters:
   enable:
     # Sorted alphabetically.
     - errcheck
-    - exportloopref
+    - copyloopvar
     - gci
     - goimports # Also includes gofmt style formatting
     - gosimple

scheduler/pkg/agent/rclone/rclone.go

@@ -143,7 +143,7 @@ func (r *RCloneClient) listenForConfigUpdates() {
 	logger := r.logger.WithField("func", "listenForConfigUpdates")
 	for config := range r.configChan {
 		logger.Info("Received config update")
-		config := config
+
 		go func() {
 			err := r.loadRcloneConfiguration(&config)
 			if err != nil {

scheduler/pkg/envoy/xdscache/resource.go

@@ -37,9 +37,9 @@ import (
 	typev3 "github.com/envoyproxy/go-control-plane/envoy/type/v3"
 	"github.com/envoyproxy/go-control-plane/pkg/resource/v3"
 	"github.com/envoyproxy/go-control-plane/pkg/wellknown"
+	"google.golang.org/protobuf/types/known/anypb"
 	duration "google.golang.org/protobuf/types/known/durationpb"
 	wrappers "google.golang.org/protobuf/types/known/wrapperspb"
-	"google.golang.org/protobuf/types/known/anypb"
 
 	"github.com/seldonio/seldon-core/scheduler/v2/pkg/util"
 )

scheduler/pkg/kafka/dataflow/server_test.go

@@ -458,7 +458,7 @@ func TestPipelineEvents(t *testing.T) {
 				select {
 				case next := <-stream.msgs:
 					psr = next
-				case <-time.After(2*time.Second):
+				case <-time.After(2 * time.Second):
 					t.Fail()
 				}
 

scheduler/pkg/server/pipeline_status_test.go

@@ -185,7 +185,7 @@ func TestPipelineStatusEvents(t *testing.T) {
 			}
 			g.Expect(s.pipelineEventStream.streams[stream]).ToNot(BeNil())
 			hub.PublishPipelineEvent(pipelineEventHandlerName, coordinator.PipelineEventMsg{
-				PipelineName: "foo", PipelineVersion: 1,})
+				PipelineName: "foo", PipelineVersion: 1})
 
 			// to allow events to propagate
 			time.Sleep(500 * time.Millisecond)