Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for podUIDs (0.29 sec)

  1. pkg/kubelet/cm/dra/state/state_checkpoint_test.go

    6aea63f7","ClaimName":"example-1","Namespace":"default","PodUIDs":{"139cdb46-f989-4f17-9561-ca10cfb509a6":{}},"ResourceHandles":[{"driverName":"test-driver.cdi.k8s.io","data":"{\"a\": \"b\"}"}],"CDIDevices":{"test-driver.cdi.k8s.io":["example.com/example=cdi-example-1"]}},{"DriverName":"test-driver.cdi.k8s.io","ClassName":"class-name-2","ClaimUID":"4cf8db2d-06c0-7d70-1a51-e59b25b2c16c","ClaimName":"example-2","Namespace":"default","PodUIDs":{"139cdb46-f989-4f17-9561-ca10cfb509a6":{}},"ResourceHa...
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:22:13 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  2. pkg/kubelet/cm/dra/claiminfo_test.go

    			claimInfo: &ClaimInfo{
    				ClaimInfoState: state.ClaimInfoState{
    					PodUIDs: sets.New[string](),
    				},
    			},
    			expectedLen: 1,
    		},
    		{
    			description: "duplicate pod reference",
    			claimInfo: &ClaimInfo{
    				ClaimInfoState: state.ClaimInfoState{
    					PodUIDs: sets.New[string](string(podUID)),
    				},
    			},
    			expectedLen: 1,
    		},
    		{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 03 13:30:31 UTC 2024
    - 21K bytes
    - Viewed (0)
  3. pkg/kubelet/cm/dra/manager_test.go

    				t.Fatalf("resourceClassName mismatch: expected %s, got %s", test.resourceClaim.Spec.ResourceClassName, claimInfo.ClassName)
    			}
    			if len(claimInfo.PodUIDs) != 1 || !claimInfo.PodUIDs.Has(string(test.pod.UID)) {
    				t.Fatalf("podUIDs mismatch: expected [%s], got %v", test.pod.UID, claimInfo.PodUIDs)
    			}
    			assert.ElementsMatchf(t, claimInfo.CDIDevices[test.resourceClaim.Status.DriverName], test.expectedCDIDevices,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 03 13:30:29 UTC 2024
    - 42K bytes
    - Viewed (0)
  4. 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)
  5. pkg/kubelet/status/status_manager.go

    	// 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)
  6. pkg/kubelet/cm/dra/manager.go

    		namespace  string
    		claimNames []string
    	}
    	inactivePodClaims := make(map[string]*podClaims)
    	m.cache.RLock()
    	for _, claimInfo := range m.cache.claimInfo {
    		for podUID := range claimInfo.PodUIDs {
    			if activePods.Has(podUID) {
    				continue
    			}
    			if inactivePodClaims[podUID] == nil {
    				inactivePodClaims[podUID] = &podClaims{
    					uid:        types.UID(podUID),
    					namespace:  claimInfo.Namespace,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 03 13:23:29 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  7. pkg/kubelet/cm/devicemanager/manager.go

    	for _, pod := range activeAndAdmittedPods {
    		podsToBeRemoved.Delete(string(pod.UID))
    	}
    	if len(podsToBeRemoved) <= 0 {
    		return
    	}
    	klog.V(3).InfoS("Pods to be removed", "podUIDs", sets.List(podsToBeRemoved))
    	m.podDevices.delete(sets.List(podsToBeRemoved))
    	// Regenerated allocatedDevices after we update pod allocation information.
    	m.allocatedDevices = m.podDevices.devices()
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 15 12:01:56 UTC 2024
    - 43K bytes
    - Viewed (0)
Back to top