Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for allowsBurst (0.09 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top