Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 309 for statefulsets (0.15 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top