Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 16 of 16 for IsRestartableInitContainer (0.31 sec)

  1. 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)
  2. pkg/printers/internalversion/printers.go

    	}
    
    	initContainers := make(map[string]*api.Container)
    	for i := range pod.Spec.InitContainers {
    		initContainers[pod.Spec.InitContainers[i].Name] = &pod.Spec.InitContainers[i]
    		if isRestartableInitContainer(&pod.Spec.InitContainers[i]) {
    			totalContainers++
    		}
    	}
    
    	initializing := false
    	for i := range pod.Status.InitContainerStatuses {
    		container := pod.Status.InitContainerStatuses[i]
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 14:04:15 UTC 2024
    - 128.3K bytes
    - Viewed (0)
  3. 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)
  4. pkg/kubelet/kubelet_pods.go

    	spec := pod.Spec
    	pendingInitialization := 0
    	failedInitialization := 0
    
    	// regular init containers
    	for _, container := range spec.InitContainers {
    		if kubetypes.IsRestartableInitContainer(&container) {
    			// Skip the restartable init containers here to handle them separately as
    			// they are slightly different from the init containers in terms of the
    			// pod phase.
    			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)
  5. pkg/kubelet/kuberuntime/kuberuntime_manager.go

    			container := &pod.Spec.InitContainers[idx]
    			// Start the next init container.
    			if err := start(ctx, "init container", metrics.InitContainer, containerStartSpec(container)); err != nil {
    				if types.IsRestartableInitContainer(container) {
    					klog.V(4).InfoS("Failed to start the restartable init container for the pod, skipping", "initContainerName", container.Name, "pod", klog.KObj(pod))
    					continue
    				}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 22 02:01:31 UTC 2024
    - 64.7K bytes
    - Viewed (0)
  6. pkg/apis/core/validation/validation.go

    		isRestartableInitContainer := false
    		for _, c := range podSpec.InitContainers {
    			if oldStatus.Name == c.Name {
    				if c.RestartPolicy != nil && *c.RestartPolicy == core.ContainerRestartPolicyAlways {
    					isRestartableInitContainer = true
    				}
    				break
    			}
    		}
    		if isRestartableInitContainer {
    			continue
    		}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 349.5K bytes
    - Viewed (0)
Back to top