- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for updateStatefulSetStatus (0.32 sec)
-
pkg/controller/statefulset/stateful_set_status_updater_test.go
} return true, update.GetObject(), nil }) if err := updater.UpdateStatefulSetStatus(context.TODO(), set, &status); err != nil { t.Errorf("UpdateStatefulSetStatus returned an error: %s", err) } if set.Status.Replicas != 2 { t.Errorf("UpdateStatefulSetStatus mutated the sets replicas %d", set.Status.Replicas) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 13 15:37:10 UTC 2022 - 5.9K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_status_updater.go
type StatefulSetStatusUpdaterInterface interface { // UpdateStatefulSetStatus sets the set's Status to status. Implementations are required to retry on conflicts, // but fail on other errors. If the returned error is nil set's Status has been successfully set to status. UpdateStatefulSetStatus(ctx context.Context, set *apps.StatefulSet, status *apps.StatefulSetStatus) error }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 13 20:32:13 UTC 2021 - 2.9K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_control.go
} } return &status, nil } // updateStatefulSetStatus updates set's Status to be equal to status. If status indicates a complete update, it is // mutated to indicate completion. If status is semantically equivalent to set's Status no update is performed. If the // returned error is nil, the update is successful. func (ssc *defaultStatefulSetControl) updateStatefulSetStatus( ctx context.Context, set *apps.StatefulSet,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 08:03:46 UTC 2024 - 30.9K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_control_test.go
return &fakeStatefulSetStatusUpdater{ setInformer.Lister(), setInformer.Informer().GetIndexer(), newRequestTracker(0, nil, 0), } } func (ssu *fakeStatefulSetStatusUpdater) UpdateStatefulSetStatus(ctx context.Context, set *apps.StatefulSet, status *apps.StatefulSetStatus) error { defer ssu.updateStatusTracker.trackParallelRequests() if err := ssu.updateStatusTracker.incWithOptionalError(); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 19:01:47 UTC 2024 - 108.7K bytes - Viewed (0)