- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 71 for statefulsets (0.27 sec)
-
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.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/scheduler/testing/framework/fake_listers.go
// StatefulSetLister implements ControllerLister on []appsv1.StatefulSet for testing purposes. type StatefulSetLister []*appsv1.StatefulSet // List returns stateful sets. func (f StatefulSetLister) List(labels.Selector) ([]*appsv1.StatefulSet, error) { return f, nil } // GetPodStatefulSets gets the StatefulSets that have the selector that match the labels on the given pod.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 20 10:14:08 UTC 2023 - 10.1K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/podtopologyspread/plugin.go
pl.services = factory.Core().V1().Services().Lister() pl.replicationCtrls = factory.Core().V1().ReplicationControllers().Lister() pl.replicaSets = factory.Apps().V1().ReplicaSets().Lister() pl.statefulSets = factory.Apps().V1().StatefulSets().Lister() } // EventsToRegister returns the possible events that may make a Pod // failed by this plugin schedulable.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:13:06 UTC 2024 - 12.7K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/rbac/bootstrappolicy/policy.go
rbacv1helpers.NewRule(Read...).Groups(discoveryGroup).Resources("endpointslices").RuleOrDie(), rbacv1helpers.NewRule(Read...).Groups(appsGroup).Resources( "controllerrevisions", "statefulsets", "statefulsets/status", "statefulsets/scale", "daemonsets", "daemonsets/status", "deployments", "deployments/status", "deployments/scale", "replicasets", "replicasets/status", "replicasets/scale").RuleOrDie(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 19:25:10 UTC 2024 - 34.4K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_test.go
t.Errorf(onPolicy("Failed to scale down StatefulSet : msg, %s", err)) } set, err = om.setsLister.StatefulSets(set.Namespace).Get(set.Name) if err != nil { t.Errorf(onPolicy("Could not get scaled down StatefulSet: %v", err)) } if set.Status.Replicas != 2 { t.Errorf(onPolicy("Failed to scale statefulset to 2 replicas")) } var claim *v1.PersistentVolumeClaim
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.1K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/rbac/bootstrappolicy/testdata/controller-roles.yaml
- list - watch - apiGroups: - apps resources: - statefulsets verbs: - get - list - watch - apiGroups: - apps resources: - statefulsets/status verbs: - update - apiGroups: - apps resources: - statefulsets/finalizers verbs: - update - apiGroups: - "" resources:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 26.6K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/rbac/bootstrappolicy/controller_policy.go
ObjectMeta: metav1.ObjectMeta{Name: saRolePrefix + "statefulset-controller"}, Rules: []rbacv1.PolicyRule{ rbacv1helpers.NewRule("list", "watch").Groups(legacyGroup).Resources("pods").RuleOrDie(), rbacv1helpers.NewRule("get", "list", "watch").Groups(appsGroup).Resources("statefulsets").RuleOrDie(), rbacv1helpers.NewRule("update").Groups(appsGroup).Resources("statefulsets/status").RuleOrDie(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 19:25:10 UTC 2024 - 28.9K bytes - Viewed (0) -
pkg/config/schema/kubeclient/resources.gen.go
} case gvr.StatefulSet: l = func(options metav1.ListOptions) (runtime.Object, error) { return c.Kube().AppsV1().StatefulSets(opts.Namespace).List(context.Background(), options) } w = func(options metav1.ListOptions) (watch.Interface, error) { return c.Kube().AppsV1().StatefulSets(opts.Namespace).Watch(context.Background(), options) } case gvr.TCPRoute:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 13:57:51 UTC 2024 - 31.1K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_control.go
logger.V(4).Info("StatefulSet is waiting for Pod to be Available prior to scale down", "statefulSet", klog.KObj(set), "pod", klog.KObj(firstUnhealthyPod)) return true, nil } logger.V(2).Info("Pod of StatefulSet is terminating for scale down", "statefulSet", klog.KObj(set), "pod", klog.KObj(condemned[i]))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 08:03:46 UTC 2024 - 30.9K bytes - Viewed (0)