- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for podUIDs (0.29 sec)
-
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) -
pkg/kubelet/cm/dra/claiminfo_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:30:31 UTC 2024 - 21K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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)