Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for isRunningAndReady (0.47 sec)

  1. pkg/controller/statefulset/stateful_set_utils_test.go

    }
    
    func TestIsRunningAndReady(t *testing.T) {
    	set := newStatefulSet(3)
    	pod := newStatefulSetPod(set, 1)
    	if isRunningAndReady(pod) {
    		t.Error("isRunningAndReady does not respect Pod phase")
    	}
    	pod.Status.Phase = v1.PodRunning
    	if isRunningAndReady(pod) {
    		t.Error("isRunningAndReady does not respect Pod condition")
    	}
    	condition := v1.PodCondition{Type: v1.PodReady, Status: v1.ConditionTrue}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 50.9K bytes
    - Viewed (0)
  2. pkg/controller/statefulset/stateful_set_utils.go

    	if utilfeature.DefaultFeatureGate.Enabled(features.PodIndexLabel) {
    		pod.Labels[apps.PodIndexLabel] = strconv.Itoa(ordinal)
    	}
    }
    
    // isRunningAndReady returns true if pod is in the PodRunning Phase, if it has a condition of PodReady.
    func isRunningAndReady(pod *v1.Pod) bool {
    	return pod.Status.Phase == v1.PodRunning && podutil.IsPodReady(pod)
    }
    
    func isRunningAndAvailable(pod *v1.Pod, minReadySeconds int32) 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)
  3. pkg/controller/statefulset/stateful_set_control.go

    	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
    			if isRunningAndAvailable(pod, minReadySeconds) {
    				status.availableReplicas++
    			}
    
    		}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 08:03:46 UTC 2024
    - 30.9K bytes
    - Viewed (0)
  4. pkg/controller/statefulset/stateful_set_control_test.go

    	pods, err := om.podsLister.Pods(set.Namespace).List(selector)
    	if err != nil {
    		return err
    	}
    	sort.Sort(ascendingOrdinal(pods))
    	for idx := 0; idx < len(pods); idx++ {
    		if idx > 0 && isRunningAndReady(pods[idx]) && !isRunningAndReady(pods[idx-1]) {
    			return fmt.Errorf("successor %s is Running and Ready while %s is not", pods[idx].Name, pods[idx-1].Name)
    		}
    
    		if ord := idx + getStartOrdinal(set); getOrdinal(pods[idx]) != ord {
    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