- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 309 for statefulsets (0.15 sec)
-
pkg/controller/statefulset/stateful_set_status_updater_test.go
updater := NewRealStatefulSetStatusUpdater(fakeClient, nil) fakeClient.AddReactor("update", "statefulsets", func(action core.Action) (bool, runtime.Object, error) { update := action.(core.UpdateAction) sts := update.GetObject().(*apps.StatefulSet) if sts.Status.ObservedGeneration != 3 { t.Errorf("expected observedGeneration to be synced with generation for statefulset %q", sts.Name) } return true, sts, 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) -
api/discovery/apis__apps__v1.json
{ "group": "autoscaling", "kind": "Scale", "name": "statefulsets/scale", "namespaced": true, "singularName": "", "verbs": [ "get", "patch", "update" ], "version": "v1" }, { "kind": "StatefulSet", "name": "statefulsets/status", "namespaced": true, "singularName": "", "verbs": [
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 15 18:18:19 UTC 2023 - 3.7K bytes - Viewed (0) -
operator/pkg/helmreconciler/wait.go
if err != nil { return false, nil, nil, err } daemonsets = append(daemonsets, ds) case name.StatefulSetStr: sts, err := cs.AppsV1().StatefulSets(o.Namespace).Get(context.TODO(), o.Name, metav1.GetOptions{}) if err != nil { return false, nil, nil, err } statefulsets = append(statefulsets, sts) } } resourceDebugInfo := map[string]string{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Dec 08 03:13:12 UTC 2023 - 13.1K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_control_test.go
simpleSetFn := func() *apps.StatefulSet { statefulSet := newStatefulSet(3) statefulSet.Spec.Ordinals = &apps.StatefulSetOrdinals{Start: int32(2)} return statefulSet } testCases := []struct { fn func(*testing.T, *apps.StatefulSet, invariantFunc) obj func() *apps.StatefulSet }{ {CreatesPodsWithStartOrdinal, simpleSetFn}, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 19:01:47 UTC 2024 - 108.7K bytes - Viewed (0) -
pkg/registry/apps/statefulset/storage/storage.go
statefulset, ok := oldObj.DeepCopyObject().(*apps.StatefulSet) if !ok { return nil, errors.NewBadRequest(fmt.Sprintf("expected existing object type to be StatefulSet, got %T", statefulset)) } // if zero-value, the existing object does not exist if len(statefulset.ResourceVersion) == 0 { return nil, errors.NewNotFound(apps.Resource("statefulsets/scale"), i.name) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 21:44:00 UTC 2023 - 12.7K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set.go
AddFunc: ssc.enqueueStatefulSet, UpdateFunc: func(old, cur interface{}) { oldPS := old.(*apps.StatefulSet) curPS := cur.(*apps.StatefulSet) if oldPS.Status.Replicas != curPS.Status.Replicas { logger.V(4).Info("Observed updated replica count for StatefulSet", "statefulSet", klog.KObj(curPS), "oldReplicas", oldPS.Status.Replicas, "newReplicas", curPS.Status.Replicas) } ssc.enqueueStatefulSet(cur) },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 18.5K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_status_updater.go
// TODO: This context.TODO should use a real context once we have RetryOnConflictWithContext _, updateErr := ssu.client.AppsV1().StatefulSets(set.Namespace).UpdateStatus(context.TODO(), set, metav1.UpdateOptions{}) if updateErr == nil { return nil } if updated, err := ssu.setLister.StatefulSets(set.Namespace).Get(set.Name); err == nil { // make a copy so we don't mutate the shared cache set = updated.DeepCopy() } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 13 20:32:13 UTC 2021 - 2.9K bytes - Viewed (0) -
releasenotes/notes/48207.yaml
apiVersion: release-notes/v2 kind: bug-fix area: traffic-management issue: - 48207 releaseNotes: - |
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Dec 13 02:31:37 UTC 2023 - 229 bytes - Viewed (0) -
pkg/registry/apps/rest/storage_apps.go
storage[resource+"/scale"] = deploymentStorage.Scale } // statefulsets if resource := "statefulsets"; apiResourceConfigSource.ResourceEnabled(appsapiv1.SchemeGroupVersion.WithResource(resource)) { statefulSetStorage, err := statefulsetstore.NewStorage(restOptionsGetter) if err != nil { return storage, err } storage[resource] = statefulSetStorage.StatefulSet storage[resource+"/status"] = statefulSetStorage.Status
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 23 18:36:33 UTC 2022 - 4.5K bytes - Viewed (0) -
releasenotes/notes/dns-round-robin.yaml
apiVersion: release-notes/v2 kind: feature area: networking issue: [31064] releaseNotes: - |
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 25 21:05:17 UTC 2021 - 188 bytes - Viewed (0)