Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for isRestartableInitContainer (0.33 sec)

  1. pkg/kubelet/status/generate.go

    			Reason: UnknownContainerStatuses,
    		}
    	}
    	unknownContainers := []string{}
    	unreadyContainers := []string{}
    
    	for _, container := range spec.InitContainers {
    		if !kubetypes.IsRestartableInitContainer(&container) {
    			continue
    		}
    
    		if containerStatus, ok := podutil.GetContainerStatus(containerStatuses, container.Name); ok {
    			if !containerStatus.Ready {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Oct 12 15:18:11 UTC 2023
    - 9.8K bytes
    - Viewed (0)
  2. pkg/kubelet/prober/prober_manager.go

    		return "UNKNOWN"
    	}
    }
    
    func getRestartableInitContainers(pod *v1.Pod) []v1.Container {
    	var restartableInitContainers []v1.Container
    	for _, c := range pod.Spec.InitContainers {
    		if kubetypes.IsRestartableInitContainer(&c) {
    			restartableInitContainers = append(restartableInitContainers, c)
    		}
    	}
    	return restartableInitContainers
    }
    
    func (m *manager) AddPod(pod *v1.Pod) {
    	m.workerLock.Lock()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 07 22:26:12 UTC 2023
    - 11K bytes
    - Viewed (0)
  3. pkg/kubelet/cm/memorymanager/policy_static.go

    			}
    
    			// See https://github.com/kubernetes/enhancements/tree/master/keps/sig-node/753-sidecar-containers#resources-calculation-for-scheduling-and-pod-admission
    			// for the detail.
    			if types.IsRestartableInitContainer(&ctr) {
    				reqRsrcsByRestartableInitCtrs[rsrcName] += qty
    			} else if reqRsrcsByRestartableInitCtrs[rsrcName]+qty > reqRsrcsByInitCtrs[rsrcName] {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Nov 12 07:34:55 UTC 2023
    - 34K bytes
    - Viewed (0)
  4. pkg/kubelet/lifecycle/predicate.go

    	// TODO: Remove this after the SidecarContainers feature gate graduates to GA.
    	if !utilfeature.DefaultFeatureGate.Enabled(features.SidecarContainers) {
    		for _, c := range admitPod.Spec.InitContainers {
    			if types.IsRestartableInitContainer(&c) {
    				message := fmt.Sprintf("Init container %q may not have a non-default restartPolicy", c.Name)
    				klog.InfoS("Failed to admit pod", "pod", klog.KObj(admitPod), "message", message)
    				return PodAdmitResult{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Oct 19 00:47:50 UTC 2023
    - 10.9K bytes
    - Viewed (0)
  5. pkg/kubelet/cm/cpumanager/policy_static.go

    	// If so, add its cpuset to the cpuset of reusable CPUs for any new allocations.
    	for _, initContainer := range pod.Spec.InitContainers {
    		if container.Name == initContainer.Name {
    			if types.IsRestartableInitContainer(&initContainer) {
    				// If the container is a restartable init container, we should not
    				// reuse its cpuset, as a restartable init container can run with
    				// regular containers.
    				break
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 06 13:16:15 UTC 2023
    - 28.8K bytes
    - Viewed (0)
  6. pkg/kubelet/cm/memorymanager/memory_manager.go

    			break
    		}
    
    		// Since a restartable init container remains running for the full
    		// duration of the pod's lifecycle, we should not remove it from the
    		// memory manager state.
    		if types.IsRestartableInitContainer(&initContainer) {
    			continue
    		}
    
    		m.policyRemoveContainerByRef(string(pod.UID), initContainer.Name)
    	}
    }
    
    // GetMemoryNUMANodes provides NUMA nodes that used to allocate the container memory
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 00:50:45 UTC 2023
    - 17.1K bytes
    - Viewed (0)
  7. pkg/kubelet/status/status_manager.go

    			return false
    		}
    
    		containerStatus := pod.Status.InitContainerStatuses[l-1]
    		if kubetypes.IsRestartableInitContainer(&container) {
    			if containerStatus.State.Running != nil &&
    				containerStatus.Started != nil && *containerStatus.Started {
    				return true
    			}
    		} else { // regular init container
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 02 16:27:19 UTC 2024
    - 44.3K bytes
    - Viewed (0)
  8. pkg/kubelet/cm/devicemanager/manager.go

    		if container.Name == initContainer.Name {
    			if err := m.allocateContainerResources(pod, container, m.devicesToReuse[string(pod.UID)]); err != nil {
    				return err
    			}
    			if !types.IsRestartableInitContainer(&initContainer) {
    				m.podDevices.addContainerAllocatedResources(string(pod.UID), container.Name, m.devicesToReuse[string(pod.UID)])
    			} else {
    				// If the init container is restartable, we need to keep the
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 15 12:01:56 UTC 2024
    - 43K bytes
    - Viewed (0)
Back to top