- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for NewRealStatefulSetStatusUpdater (0.27 sec)
-
pkg/controller/statefulset/stateful_set_status_updater_test.go
) func TestStatefulSetUpdaterUpdatesSetStatus(t *testing.T) { set := newStatefulSet(3) status := apps.StatefulSetStatus{ObservedGeneration: 1, Replicas: 2} fakeClient := &fake.Clientset{} updater := NewRealStatefulSetStatusUpdater(fakeClient, nil) fakeClient.AddReactor("update", "statefulsets", func(action core.Action) (bool, runtime.Object, error) { update := action.(core.UpdateAction) return true, update.GetObject(), nil })
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
UpdateStatefulSetStatus(ctx context.Context, set *apps.StatefulSet, status *apps.StatefulSetStatus) error } // NewRealStatefulSetStatusUpdater returns a StatefulSetStatusUpdaterInterface that updates the Status of a StatefulSet, // using the supplied client and setLister. func NewRealStatefulSetStatusUpdater( client clientset.Interface, setLister appslisters.StatefulSetLister) StatefulSetStatusUpdaterInterface {
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.go
kubeClient: kubeClient, control: NewDefaultStatefulSetControl( NewStatefulPodControl( kubeClient, podInformer.Lister(), pvcInformer.Lister(), recorder), NewRealStatefulSetStatusUpdater(kubeClient, setInformer.Lister()), history.NewHistory(kubeClient, revInformer.Lister()), ), pvcListerSynced: pvcInformer.Informer().HasSynced, revListerSynced: revInformer.Informer().HasSynced,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 18.5K bytes - Viewed (0)