- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for allowsBurst (0.09 sec)
-
pkg/controller/statefulset/stateful_set_utils.go
// isHealthy returns true if pod is running and ready and has not been terminated func isHealthy(pod *v1.Pod) bool { return isRunningAndReady(pod) && !isTerminating(pod) } // allowsBurst is true if the alpha burst annotation is set. func allowsBurst(set *apps.StatefulSet) bool { return set.Spec.PodManagementPolicy == apps.ParallelPodManagement }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 26.7K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_control.go
} // If the StatefulSet is being deleted, don't do anything other than updating // status. if set.DeletionTimestamp != nil { return &status, nil } monotonic := !allowsBurst(set) // First, process each living replica. Exit if we run into an error or something blocking in monotonic mode. processReplicaFn := func(i int) (bool, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 08:03:46 UTC 2024 - 30.9K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_control_test.go
// 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 { expectedNumberOfCreateRequests = int(*set.Spec.Replicas + 1) } if om.createPodTracker.requests != expectedNumberOfCreateRequests {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 19:01:47 UTC 2024 - 108.7K bytes - Viewed (0)