- Sort Score
- Result 10 results
- Languages All
Results 11 - 16 of 16 for IsRestartableInitContainer (0.31 sec)
-
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) -
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) -
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) -
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) -
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) -
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)