Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for PodID (0.03 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top