From 9358443e373c0f3e9a2fbd3a59b8ae47e292d2f8 Mon Sep 17 00:00:00 2001 From: matoval Date: Sun, 8 Dec 2024 17:27:36 -0800 Subject: [PATCH] Run golangci-lint --- pkg/workceptor/kubernetes_test.go | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/pkg/workceptor/kubernetes_test.go b/pkg/workceptor/kubernetes_test.go index c5a2ffa8c..bb23bdf27 100644 --- a/pkg/workceptor/kubernetes_test.go +++ b/pkg/workceptor/kubernetes_test.go @@ -24,10 +24,10 @@ import ( "k8s.io/apimachinery/pkg/selection" "k8s.io/apimachinery/pkg/watch" "k8s.io/client-go/kubernetes" + "k8s.io/client-go/kubernetes/scheme" "k8s.io/client-go/rest" fakerest "k8s.io/client-go/rest/fake" "k8s.io/client-go/tools/remotecommand" - "k8s.io/client-go/kubernetes/scheme" ) func startNetceptorNodeWithWorkceptor() (*workceptor.KubeUnit, error) { @@ -455,11 +455,11 @@ func TestKubeLoggingWithReconnect(t *testing.T) { kubeConfig.NewkubeWorker(mockBaseWorkUnit, w, "", "", mockKubeAPI) tests := []struct { - name string + name string expectedCalls func() }{ { - name: "Kube error should be read", + name: "Kube error should be read", expectedCalls: func() { lock := &sync.RWMutex{} mockBaseWorkUnitForWorkUnit.EXPECT().GetStatusLock().Return(lock).AnyTimes() @@ -482,6 +482,7 @@ func TestKubeLoggingWithReconnect(t *testing.T) { StatusCode: http.StatusOK, Body: io.NopCloser(strings.NewReader("2024-12-09T00:31:18.823849250Z HI\n kube error")), } + return resp, nil }), NegotiatedSerializer: scheme.Codecs.WithoutConversion(),