Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for IsPodTerminationRequested (0.3 sec)

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