- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for IsPodTerminationRequested (0.3 sec)
-
pkg/kubelet/kuberuntime/fake_kuberuntime_manager.go
func newFakePodStateProvider() *fakePodStateProvider { return &fakePodStateProvider{ terminated: make(map[types.UID]struct{}), removed: make(map[types.UID]struct{}), } } func (f *fakePodStateProvider) IsPodTerminationRequested(uid types.UID) bool { _, found := f.removed[uid] return found } func (f *fakePodStateProvider) ShouldPodRuntimeBeRemoved(uid types.UID) bool { _, found := f.terminated[uid] return found }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 16 17:55:59 UTC 2024 - 5.1K bytes - Viewed (0) -
pkg/kubelet/pod_workers_test.go
} if podWorkers.ShouldPodContainersBeTerminating(types.UID("2")) { t.Errorf("Expected pod to not be terminating") } if !podWorkers.IsPodTerminationRequested(types.UID("0")) { t.Errorf("Expected pod to be terminating") } if podWorkers.IsPodTerminationRequested(types.UID("2")) { t.Errorf("Expected pod to not be terminating") } if podWorkers.CouldHaveRunningContainers(types.UID("0")) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 75.6K bytes - Viewed (0) -
pkg/kubelet/pod_workers.go
// after termination has been requested for a pod. Callers must ensure that the // syncPod method is non-blocking when their data is absent. ShouldPodBeFinished(uid types.UID) bool // IsPodTerminationRequested returns true when pod termination has been requested // until the termination completes and the pod is removed from config. This should // not be used in cleanup loops because it will return false if the pod has already
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 02 13:22:37 UTC 2024 - 74.8K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_manager.go
) // podStateProvider can determine if none of the elements are necessary to retain (pod content) // or if none of the runtime elements are necessary to retain (containers) type podStateProvider interface { IsPodTerminationRequested(kubetypes.UID) bool ShouldPodContentBeRemoved(kubetypes.UID) bool ShouldPodRuntimeBeRemoved(kubetypes.UID) bool } type kubeGenericRuntimeManager struct { runtimeName string
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/kubelet/kubelet.go
return false, fmt.Errorf("%s: %v", NetworkNotReadyErrorMsg, err) } // ensure the kubelet knows about referenced secrets or configmaps used by the pod if !kl.podWorkers.IsPodTerminationRequested(pod.UID) { if kl.secretManager != nil { kl.secretManager.RegisterPod(pod) } if kl.configMapManager != nil { kl.configMapManager.RegisterPod(pod) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods.go
if kl.podWorkers.IsPodKnownTerminated(p.UID) { continue } // terminal pods are considered inactive UNLESS they are actively terminating if kl.isAdmittedPodTerminal(p) && !kl.podWorkers.IsPodTerminationRequested(p.UID) { continue } filteredPods = append(filteredPods, p) } return filteredPods } // isAdmittedPodTerminal returns true if the provided config source pod is in
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0)