- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for PodID (0.03 sec)
-
pkg/controller/daemon/daemon_controller_test.go
func (f *fakePodControl) DeletePod(ctx context.Context, namespace string, podID string, object runtime.Object) error { f.Lock() defer f.Unlock() if err := f.FakePodControl.DeletePod(ctx, namespace, podID, object); err != nil { return fmt.Errorf("failed to delete pod %q", podID) } pod, ok := f.podIDMap[podID] if !ok { return fmt.Errorf("pod %q does not exist", podID) } f.podStore.Delete(pod) delete(f.podIDMap, podID)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.4K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue_test.go
if _, ok, _ := q.podBackoffQ.Get(podInfo); !ok { t.Errorf("pod %v is not in the backoff queue", podID) } // Moved out of the backoff queue after timeout. cl.Step(backoff) q.flushBackoffQCompleted(logger) if _, ok, _ := q.podBackoffQ.Get(podInfo); ok { t.Errorf("pod %v is still in the backoff queue", podID) } }) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 146.9K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
func (kl *Kubelet) cleanUpContainersInPod(podID types.UID, exitedContainerID string) { if podStatus, err := kl.podCache.Get(podID); err == nil { // When an evicted or deleted pod has already synced, all containers can be removed. removeAll := kl.podWorkers.ShouldPodContentBeRemoved(podID) kl.containerDeletor.deleteContainersInPod(exitedContainerID, podStatus, removeAll) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0)