Skip to content

Commit

Permalink
Run golangci-lint
Browse files Browse the repository at this point in the history
  • Loading branch information
matoval committed Dec 9, 2024
1 parent e8e5520 commit 9358443
Showing 1 changed file with 4 additions and 3 deletions.
7 changes: 4 additions & 3 deletions pkg/workceptor/kubernetes_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -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) {
Expand Down Expand Up @@ -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()
Expand All @@ -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(),
Expand Down

0 comments on commit 9358443

Please sign in to comment.