Skip to content

Commit 4066719

Browse files
authored
Merge pull request kubernetes#92415 from wawa0210/statefulset-staticcheck
fix pkg/controller/statefulset staticcheck
2 parents da37b7f + d360be0 commit 4066719

File tree

4 files changed

+9
-11
lines changed

4 files changed

+9
-11
lines changed

hack/.staticcheck_failures

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,6 @@ pkg/controller/nodeipam
55
pkg/controller/podautoscaler
66
pkg/controller/replicaset
77
pkg/controller/resourcequota
8-
pkg/controller/statefulset
98
pkg/volume/azure_dd
109
pkg/volume/gcepd
1110
pkg/volume/rbd

pkg/controller/statefulset/stateful_set.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -374,7 +374,7 @@ func (ssc *StatefulSetController) resolveControllerRef(namespace string, control
374374
func (ssc *StatefulSetController) enqueueStatefulSet(obj interface{}) {
375375
key, err := controller.KeyFunc(obj)
376376
if err != nil {
377-
utilruntime.HandleError(fmt.Errorf("Couldn't get key for object %+v: %v", obj, err))
377+
utilruntime.HandleError(fmt.Errorf("couldn't get key for object %+v: %v", obj, err))
378378
return
379379
}
380380
ssc.queue.Add(key)
@@ -389,7 +389,7 @@ func (ssc *StatefulSetController) processNextWorkItem() bool {
389389
}
390390
defer ssc.queue.Done(key)
391391
if err := ssc.sync(key.(string)); err != nil {
392-
utilruntime.HandleError(fmt.Errorf("Error syncing StatefulSet %v, requeuing: %v", key.(string), err))
392+
utilruntime.HandleError(fmt.Errorf("error syncing StatefulSet %v, requeuing: %v", key.(string), err))
393393
ssc.queue.AddRateLimited(key)
394394
} else {
395395
ssc.queue.Forget(key)

pkg/controller/statefulset/stateful_set_control_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -238,7 +238,7 @@ func ReplacesPods(t *testing.T, set *apps.StatefulSet, invariants invariantFunc)
238238
if err != nil {
239239
t.Fatalf("Error getting updated StatefulSet: %v", err)
240240
}
241-
if pods, err = spc.setPodReady(set, i); err != nil {
241+
if _, err = spc.setPodReady(set, i); err != nil {
242242
t.Error(err)
243243
}
244244
}

pkg/controller/statefulset/stateful_set_test.go

Lines changed: 6 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -98,11 +98,11 @@ func TestStatefulSetControllerRespectsTermination(t *testing.T) {
9898
if set.Status.Replicas != 3 {
9999
t.Errorf("set.Status.Replicas = %v; want 3", set.Status.Replicas)
100100
}
101-
pods, err := spc.addTerminatingPod(set, 3)
101+
_, err := spc.addTerminatingPod(set, 3)
102102
if err != nil {
103103
t.Error(err)
104104
}
105-
pods, err = spc.addTerminatingPod(set, 4)
105+
pods, err := spc.addTerminatingPod(set, 4)
106106
if err != nil {
107107
t.Error(err)
108108
}
@@ -152,7 +152,7 @@ func TestStatefulSetControllerBlocksScaling(t *testing.T) {
152152
*set.Spec.Replicas = 5
153153
fakeResourceVersion(set)
154154
spc.setsIndexer.Update(set)
155-
pods, err := spc.setPodTerminated(set, 0)
155+
_, err := spc.setPodTerminated(set, 0)
156156
if err != nil {
157157
t.Error("Failed to set pod terminated at ordinal 0")
158158
}
@@ -162,7 +162,7 @@ func TestStatefulSetControllerBlocksScaling(t *testing.T) {
162162
if err != nil {
163163
t.Error(err)
164164
}
165-
pods, err = spc.podsLister.Pods(set.Namespace).List(selector)
165+
pods, err := spc.podsLister.Pods(set.Namespace).List(selector)
166166
if err != nil {
167167
t.Error(err)
168168
}
@@ -227,7 +227,7 @@ func TestStatefulSetControllerDeletionTimestampRace(t *testing.T) {
227227
t.Fatal(err)
228228
}
229229
revision.OwnerReferences = nil
230-
revision, err = ssh.CreateControllerRevision(set, revision, set.Status.CollisionCount)
230+
_, err = ssh.CreateControllerRevision(set, revision, set.Status.CollisionCount)
231231
if err != nil {
232232
t.Fatal(err)
233233
}
@@ -700,11 +700,10 @@ func scaleUpStatefulSetController(set *apps.StatefulSet, ssc *StatefulSetControl
700700
return err
701701
}
702702
ord := len(pods) - 1
703-
pod := getPodAtOrdinal(pods, ord)
704703
if pods, err = spc.setPodPending(set, ord); err != nil {
705704
return err
706705
}
707-
pod = getPodAtOrdinal(pods, ord)
706+
pod := getPodAtOrdinal(pods, ord)
708707
ssc.addPod(pod)
709708
fakeWorker(ssc)
710709
pod = getPodAtOrdinal(pods, ord)

0 commit comments

Comments
 (0)