Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for RemoveOrphanedStatuses (0.55 sec)

  1. pkg/kubelet/status/testing/mock_pod_status_provider.go

    }
    
    // RemoveOrphanedStatuses mocks base method.
    func (m *MockManager) RemoveOrphanedStatuses(podUIDs map[types.UID]bool) {
    	m.ctrl.T.Helper()
    	m.ctrl.Call(m, "RemoveOrphanedStatuses", podUIDs)
    }
    
    // RemoveOrphanedStatuses indicates an expected call of RemoveOrphanedStatuses.
    func (mr *MockManagerMockRecorder) RemoveOrphanedStatuses(podUIDs any) *gomock.Call {
    	mr.mock.ctrl.T.Helper()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  2. pkg/kubelet/status/fake_status_manager.go

    	klog.InfoS("SetContainerStartup()")
    	return
    }
    
    func (m *fakeManager) TerminatePod(pod *v1.Pod) {
    	klog.InfoS("TerminatePod()")
    	return
    }
    
    func (m *fakeManager) RemoveOrphanedStatuses(podUIDs map[types.UID]bool) {
    	klog.InfoS("RemoveOrphanedStatuses()")
    	return
    }
    
    func (m *fakeManager) GetContainerResourceAllocation(podUID string, containerName string) (v1.ResourceList, bool) {
    	klog.InfoS("GetContainerResourceAllocation()")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 07 05:59:34 UTC 2023
    - 2.7K bytes
    - Viewed (0)
  3. pkg/kubelet/status/status_manager.go

    	// TerminatePod resets the container status for the provided pod to terminated and triggers
    	// a status update.
    	TerminatePod(pod *v1.Pod)
    
    	// RemoveOrphanedStatuses scans the status cache and removes any entries for pods not included in
    	// the provided podUIDs.
    	RemoveOrphanedStatuses(podUIDs map[types.UID]bool)
    
    	// GetContainerResourceAllocation returns checkpointed AllocatedResources value for the 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)
  4. pkg/kubelet/kubelet_pods.go

    	podUIDs := make(map[types.UID]bool)
    	for _, pod := range pods {
    		podUIDs[pod.UID] = true
    	}
    	for _, pod := range mirrorPods {
    		podUIDs[pod.UID] = true
    	}
    	kl.statusManager.RemoveOrphanedStatuses(podUIDs)
    }
    
    // HandlePodCleanups performs a series of cleanup work, including terminating
    // pod workers, killing unwanted pods, and removing orphaned volumes/pod
    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