Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 430 for initContainer (0.2 sec)

  1. pkg/kubelet/types/pod_update.go

    }
    
    // IsRestartableInitContainer returns true if the initContainer has
    // ContainerRestartPolicyAlways.
    func IsRestartableInitContainer(initContainer *v1.Container) bool {
    	if initContainer.RestartPolicy == nil {
    		return false
    	}
    
    	return *initContainer.RestartPolicy == v1.ContainerRestartPolicyAlways
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 07 22:26:12 UTC 2023
    - 6.4K bytes
    - Viewed (0)
  2. pkg/kubelet/container/sync_result.go

    	KillContainer SyncAction = "KillContainer"
    	// SetupNetwork action
    	SetupNetwork SyncAction = "SetupNetwork"
    	// TeardownNetwork action
    	TeardownNetwork SyncAction = "TeardownNetwork"
    	// InitContainer action
    	InitContainer SyncAction = "InitContainer"
    	// CreatePodSandbox action
    	CreatePodSandbox SyncAction = "CreatePodSandbox"
    	// ConfigPodSandbox action
    	ConfigPodSandbox SyncAction = "ConfigPodSandbox"
    	// KillPodSandbox action
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 19 15:48:08 UTC 2020
    - 4.6K bytes
    - Viewed (0)
  3. pkg/kube/inject/webhook.go

    		pod.Spec.InitContainers = modifyContainers(pod.Spec.InitContainers, ValidationContainerName, MoveFirst)
    		// Init container must be last to allow any traffic to pass before iptables is setup
    		pod.Spec.InitContainers = modifyContainers(pod.Spec.InitContainers, InitContainerName, MoveLast)
    		pod.Spec.InitContainers = modifyContainers(pod.Spec.InitContainers, EnableCoreDumpName, MoveLast)
    	}
    
    	return nil
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 14 17:59:39 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/memorymanager/policy_static.go

    				}
    			}
    
    			s.SetMemoryBlocks(podUID, initContainer.Name, initContainerBlocks)
    		}
    	}
    }
    
    func isRegularInitContainer(pod *v1.Pod, container *v1.Container) bool {
    	for _, initContainer := range pod.Spec.InitContainers {
    		if initContainer.Name == container.Name {
    			return !types.IsRestartableInitContainer(&initContainer)
    		}
    	}
    
    	return false
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Nov 12 07:34:55 UTC 2023
    - 34K bytes
    - Viewed (0)
  5. pkg/kubelet/cm/memorymanager/memory_manager.go

    	for _, initContainer := range pod.Spec.InitContainers {
    		if initContainer.Name == container.Name {
    			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
    		}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 00:50:45 UTC 2023
    - 17.1K bytes
    - Viewed (0)
  6. pkg/kubelet/status/generate.go

    		}
    	}
    
    	return v1.PodCondition{
    		Type:   v1.PodReady,
    		Status: v1.ConditionTrue,
    	}
    }
    
    func isInitContainerInitialized(initContainer *v1.Container, containerStatus *v1.ContainerStatus) bool {
    	if kubetypes.IsRestartableInitContainer(initContainer) {
    		if containerStatus.Started == nil || !*containerStatus.Started {
    			return false
    		}
    	} else { // regular init container
    		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)
  7. pkg/kubelet/prober/prober_manager.go

    		podStatus.InitContainerStatuses[i].Started = &started
    
    		initContainer, ok := kubeutil.GetContainerByIndex(pod.Spec.InitContainers, podStatus.InitContainerStatuses, i)
    		if !ok {
    			klog.V(4).InfoS("Mismatch between pod spec and status, likely programmer error", "pod", klog.KObj(pod), "containerName", c.Name)
    			continue
    		}
    		if !kubetypes.IsRestartableInitContainer(&initContainer) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 07 22:26:12 UTC 2023
    - 11K bytes
    - Viewed (0)
  8. pkg/kubelet/cm/cpumanager/policy_static.go

    	}
    	// Check if the container is an init container.
    	// 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
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 06 13:16:15 UTC 2023
    - 28.8K bytes
    - Viewed (0)
  9. pkg/test/kube/dump.go

    	return string(n)
    }
    
    const (
    	maxCoreDumpedPods                      = 5
    	proxyContainer      wellKnownContainer = "istio-proxy"
    	discoveryContainer  wellKnownContainer = "discovery"
    	initContainer       wellKnownContainer = "istio-init"
    	validationContainer wellKnownContainer = "istio-validation"
    )
    
    var coreDumpedPods = atomic.NewInt32(0)
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 22.2K bytes
    - Viewed (0)
  10. pkg/kubelet/cm/devicemanager/manager.go

    	// ever change those semantics, this logic will need to be amended.
    	for _, initContainer := range pod.Spec.InitContainers {
    		if container.Name == initContainer.Name {
    			if err := m.allocateContainerResources(pod, container, m.devicesToReuse[string(pod.UID)]); err != nil {
    				return err
    			}
    			if !types.IsRestartableInitContainer(&initContainer) {
    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