Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for runForAll (0.17 sec)

  1. pkg/controller/statefulset/stateful_set_control.go

    	logger.V(2).Info("Pod of StatefulSet is terminating for scale down",
    		"statefulSet", klog.KObj(set), "pod", klog.KObj(condemned[i]))
    	return true, ssc.podControl.DeleteStatefulPod(set, condemned[i])
    }
    
    func runForAll(pods []*v1.Pod, fn func(i int) (bool, error), monotonic bool) (bool, error) {
    	if monotonic {
    		for i := range pods {
    			if shouldExit, err := fn(i); shouldExit || err != nil {
    				return true, err
    			}
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 08:03:46 UTC 2024
    - 30.9K bytes
    - Viewed (0)
Back to top