Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for isPodPhaseTerminal (0.3 sec)

  1. pilot/pkg/serviceregistry/kube/controller/pod.go

    	if isPodPhaseTerminal(pod.Status.Phase) {
    		return false
    	}
    
    	if len(pod.Status.PodIP) == 0 && len(pod.Status.PodIPs) == 0 {
    		return false
    	}
    
    	if pod.DeletionTimestamp != nil {
    		return false
    	}
    
    	return true
    }
    
    // isPodPhaseTerminal returns true if the pod's phase is terminal.
    func isPodPhaseTerminal(phase v1.PodPhase) bool {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  2. pkg/api/v1/pod/util.go

    }
    
    // IsPodTerminal returns true if a pod is terminal, all containers are stopped and cannot ever regress.
    func IsPodTerminal(pod *v1.Pod) bool {
    	return IsPodPhaseTerminal(pod.Status.Phase)
    }
    
    // IsPodPhaseTerminal returns true if the pod's phase is terminal.
    func IsPodPhaseTerminal(phase v1.PodPhase) bool {
    	return phase == v1.PodFailed || phase == v1.PodSucceeded
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Feb 24 17:18:04 UTC 2023
    - 13.2K bytes
    - Viewed (0)
  3. pkg/kubelet/status/status_manager.go

    		if !kubetypes.PodConditionByKubelet(c.Type) {
    			podConditions = append(podConditions, c)
    		}
    	}
    
    	transitioningToTerminalPhase := !podutil.IsPodPhaseTerminal(oldPodStatus.Phase) && podutil.IsPodPhaseTerminal(newPodStatus.Phase)
    
    	for _, c := range newPodStatus.Conditions {
    		if kubetypes.PodConditionByKubelet(c.Type) {
    			podConditions = append(podConditions, c)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 02 16:27:19 UTC 2024
    - 44.3K bytes
    - Viewed (0)
  4. pkg/controller/disruption/disruption.go

    	// on pods in terminal phase are not stale to avoid unnecessary status updates.
    	if cond == nil || cond.Status != v1.ConditionTrue || cond.Reason == v1.PodReasonTerminationByKubelet || apipod.IsPodPhaseTerminal(pod.Status.Phase) {
    		return false, 0
    	}
    	waitFor := dc.stalePodDisruptionTimeout - dc.clock.Since(cond.LastTransitionTime.Time)
    	if waitFor < 0 {
    		waitFor = 0
    	}
    	return true, waitFor
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 36.1K bytes
    - Viewed (0)
  5. pkg/controller/resourceclaim/controller.go

    	}
    	return keys, nil
    }
    
    // isPodDone returns true if it is certain that none of the containers are running and never will run.
    func isPodDone(pod *v1.Pod) bool {
    	return podutil.IsPodPhaseTerminal(pod.Status.Phase) ||
    		// Deleted and not scheduled:
    		pod.DeletionTimestamp != nil && pod.Spec.NodeName == ""
    }
    
    // claimPodOwnerIndexFunc is an index function that returns the pod UIDs of
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 09 03:34:25 UTC 2024
    - 37.1K bytes
    - Viewed (0)
  6. pkg/kubelet/kubelet_pods.go

    	terminalPodsToDelete := make(map[types.UID]*v1.Pod)
    	for _, pod := range allPods {
    		if pod.DeletionTimestamp == nil {
    			// skip pods which don't have a deletion timestamp
    			continue
    		}
    		if !podutil.IsPodPhaseTerminal(pod.Status.Phase) {
    			// skip the non-terminal pods
    			continue
    		}
    		if _, knownPod := workingPods[pod.UID]; knownPod {
    			// skip pods known to pod workers
    			continue
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
  7. pkg/printers/internalversion/printers.go

    				reason = "NotReady"
    			}
    		}
    	}
    
    	if pod.DeletionTimestamp != nil && pod.Status.Reason == node.NodeUnreachablePodReason {
    		reason = "Unknown"
    	} else if pod.DeletionTimestamp != nil && !podutil.IsPodPhaseTerminal(apiv1.PodPhase(podPhase)) {
    		reason = "Terminating"
    	}
    
    	restartsStr := strconv.Itoa(restarts)
    	if restarts != 0 && !lastRestartDate.IsZero() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 14:04:15 UTC 2024
    - 128.3K bytes
    - Viewed (0)
Back to top