Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for isRestartableInitContainer (0.22 sec)

  1. pkg/kubelet/apis/podresources/server_v1.go

    			pRes.Containers = make([]*podresourcesv1.ContainerResources, 0, len(pod.Spec.InitContainers)+len(pod.Spec.Containers))
    
    			for _, container := range pod.Spec.InitContainers {
    				if !types.IsRestartableInitContainer(&container) {
    					continue
    				}
    
    				pRes.Containers = append(pRes.Containers, p.getContainerResources(pod, &container))
    			}
    		}
    
    		for _, container := range pod.Spec.Containers {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 21 13:00:09 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  2. pkg/kubelet/types/pod_update.go

    func IsNodeCriticalPod(pod *v1.Pod) bool {
    	return IsCriticalPod(pod) && (pod.Spec.PriorityClassName == scheduling.SystemNodeCritical)
    }
    
    // IsRestartableInitContainer returns true if the initContainer has
    // ContainerRestartPolicyAlways.
    func IsRestartableInitContainer(initContainer *v1.Container) bool {
    	if initContainer.RestartPolicy == nil {
    		return false
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 07 22:26:12 UTC 2023
    - 6.4K bytes
    - Viewed (0)
  3. pkg/kubelet/kuberuntime/kuberuntime_termination_order.go

    		// get the init containers in reverse order
    		ic := pod.Spec.InitContainers[len(pod.Spec.InitContainers)-i-1]
    
    		to.terminated[ic.Name] = make(chan struct{})
    
    		if types.IsRestartableInitContainer(&ic) {
    			// sidecars need to wait for all main containers to exit
    			to.prereqs[ic.Name] = append(to.prereqs[ic.Name], mainContainerChannels...)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Oct 18 00:07:21 UTC 2023
    - 3.8K bytes
    - Viewed (0)
Back to top