- Sort Score
- Result 10 results
- Languages All
Results 11 - 16 of 16 for isCreate (0.17 sec)
-
staging/src/k8s.io/apiserver/pkg/endpoints/installer.go
} namespaceScoped = scoper.NamespaceScoped() } // what verbs are supported by the storage, used to know what verbs we support per path creater, isCreater := storage.(rest.Creater) namedCreater, isNamedCreater := storage.(rest.NamedCreater) lister, isLister := storage.(rest.Lister) getter, isGetter := storage.(rest.Getter)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 18:15:22 UTC 2024 - 51.5K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_control.go
} func computeReplicaStatus(pods []*v1.Pod, minReadySeconds int32, currentRevision, updateRevision *apps.ControllerRevision) replicaStatus { status := replicaStatus{} for _, pod := range pods { if isCreated(pod) { status.replicas++ } // count the number of running and ready replicas if isRunningAndReady(pod) { status.readyReplicas++ // count the number of running and available replicas
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 08:03:46 UTC 2024 - 30.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher.go
return wc.watcher.client.RequestProgress(wc.ctx) } // sync tries to retrieve existing data and send them to process. // The revision to watch will be set to the revision in response. // All events sent will have isCreated=true func (wc *watchChan) sync() error { opts := []clientv3.OpOption{} if wc.recursive { opts = append(opts, clientv3.WithLimit(defaultWatcherMaxLimit)) rangeEnd := clientv3.GetPrefixRangeEnd(wc.key)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 25 10:26:38 UTC 2023 - 18.9K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_utils.go
} func isRunningAndAvailable(pod *v1.Pod, minReadySeconds int32) bool { return podutil.IsPodAvailable(pod, minReadySeconds, metav1.Now()) } // isCreated returns true if pod has been created and is maintained by the API server func isCreated(pod *v1.Pod) bool { return pod.Status.Phase != "" } // isPending returns true if pod has a Phase of PodPending func isPending(pod *v1.Pod) bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 26.7K bytes - Viewed (0) -
cmd/iam-store.go
d.Policy = doc.Policy return nil } *d = doc return nil } // key options type options struct { ttl int64 // expiry in seconds } type iamWatchEvent struct { isCreated bool // !isCreated implies a delete event. keyPath string } // iamCache contains in-memory cache of IAM data. type iamCache struct { updatedAt time.Time // map of policy names to policy definitions
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 75.8K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_control_test.go
t.Error(err) } recreatedPod := findPodByOrdinal(pods, terminalPodOrdinal) // new recreated pod should have empty phase if recreatedPod == nil || isCreated(recreatedPod) { t.Error("StatefulSet did not recreate failed Pod") } expectedNumberOfCreateRequests := 2 if monotonic := !allowsBurst(set); !monotonic {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 19:01:47 UTC 2024 - 108.7K bytes - Viewed (0)