Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for getPodCondition (0.33 sec)

  1. pilot/pkg/controllers/untaint/nodeuntainter.go

    	return condition != nil && condition.Status == v1.ConditionTrue
    }
    
    func GetPodReadyCondition(status v1.PodStatus) *v1.PodCondition {
    	_, condition := GetPodCondition(&status, v1.PodReady)
    	return condition
    }
    
    func GetPodCondition(status *v1.PodStatus, conditionType v1.PodConditionType) (int, *v1.PodCondition) {
    	if status == nil {
    		return -1, nil
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat Apr 13 00:50:31 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  2. pilot/pkg/serviceregistry/kube/controller/pod.go

    	return condition != nil && condition.Status == v1.ConditionTrue
    }
    
    func GetPodReadyCondition(status v1.PodStatus) *v1.PodCondition {
    	_, condition := GetPodCondition(&status, v1.PodReady)
    	return condition
    }
    
    func GetPodCondition(status *v1.PodStatus, conditionType v1.PodConditionType) (int, *v1.PodCondition) {
    	if status == nil {
    		return -1, nil
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  3. pkg/api/pod/util.go

    func GetPodReadyCondition(status api.PodStatus) *api.PodCondition {
    	_, condition := GetPodCondition(&status, api.PodReady)
    	return condition
    }
    
    // GetPodCondition extracts the provided condition from the given status and returns that.
    // Returns nil and -1 if the condition is not present, and the index of the located condition.
    func GetPodCondition(status *api.PodStatus, conditionType api.PodConditionType) (int, *api.PodCondition) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 41.3K bytes
    - Viewed (0)
  4. pkg/controller/job/backoff_utils.go

    			finishTime = &containerState.State.Terminated.FinishedAt.Time
    		}
    	}
    	return finishTime
    }
    
    func getFinishTimeFromPodReadyFalseCondition(p *v1.Pod) *time.Time {
    	if _, c := apipod.GetPodCondition(&p.Status, v1.PodReady); c != nil && c.Status == v1.ConditionFalse && !c.LastTransitionTime.Time.IsZero() {
    		return &c.LastTransitionTime.Time
    	}
    	return nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 07:46:41 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  5. pkg/kubelet/status/status_manager.go

    func updateLastTransitionTime(status, oldStatus *v1.PodStatus, conditionType v1.PodConditionType) {
    	_, condition := podutil.GetPodCondition(status, conditionType)
    	if condition == nil {
    		return
    	}
    	// Need to set LastTransitionTime.
    	lastTransitionTime := metav1.Now()
    	_, oldCondition := podutil.GetPodCondition(oldStatus, conditionType)
    	if oldCondition != nil && condition.Status == oldCondition.Status {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 02 16:27:19 UTC 2024
    - 44.3K bytes
    - Viewed (0)
  6. pkg/controller/disruption/disruption.go

    }
    
    func (dc *DisruptionController) nonTerminatingPodHasStaleDisruptionCondition(pod *v1.Pod) (bool, time.Duration) {
    	if pod.DeletionTimestamp != nil {
    		return false, 0
    	}
    	_, cond := apipod.GetPodCondition(&pod.Status, v1.DisruptionTarget)
    	// Pod disruption conditions added by kubelet are never considered stale because the condition might take
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 36.1K bytes
    - Viewed (0)
  7. pkg/controller/statefulset/stateful_set_control_test.go

    	}
    	condition := v1.PodCondition{Type: v1.PodReady, Status: v1.ConditionTrue, LastTransitionTime: metav1.Time{Time: lastTransitionTime}}
    	_, existingCondition := podutil.GetPodCondition(&pod.Status, condition.Type)
    	if existingCondition != nil {
    		existingCondition.Status = v1.ConditionTrue
    		existingCondition.LastTransitionTime = metav1.Time{Time: lastTransitionTime}
    	} else {
    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