- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for podUIDs (0.2 sec)
-
pkg/kubelet/cm/dra/state/zz_generated.deepcopy.go
) // DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil. func (in *ClaimInfoState) DeepCopyInto(out *ClaimInfoState) { *out = *in if in.PodUIDs != nil { in, out := &in.PodUIDs, &out.PodUIDs *out = make(sets.Set[string], len(*in)) for key, val := range *in { (*out)[key] = val } } if in.ResourceHandles != nil { in, out := &in.ResourceHandles, &out.ResourceHandles
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:23:27 UTC 2024 - 1.9K bytes - Viewed (0) -
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/state/state_checkpoint.go
ClaimUID types.UID // ClaimName is a name of the resource claim ClaimName string // Namespace is a claim namespace Namespace string // PodUIDs is a set of pod UIDs that reference a resource PodUIDs sets.Set[string] // ResourceHandles is a list of opaque resource data for processing by a specific kubelet plugin ResourceHandles []resourcev1alpha2.ResourceHandle
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:23:27 UTC 2024 - 4.3K 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/claiminfo.go
// addPodReference adds a pod reference to the claim info. func (info *ClaimInfo) addPodReference(podUID types.UID) { info.PodUIDs.Insert(string(podUID)) } // hasPodReference checks if a pod reference exists in the claim info. func (info *ClaimInfo) hasPodReference(podUID types.UID) bool { return info.PodUIDs.Has(string(podUID)) } // deletePodReference deletes a pod reference from the claim info.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:30:31 UTC 2024 - 7.9K bytes - Viewed (0) -
pkg/kubelet/cm/dra/state/checkpoint.go
DriverName: entry.DriverName, ClassName: entry.ClassName, ClaimUID: entry.ClaimUID, ClaimName: entry.ClaimName, Namespace: entry.Namespace, PodUIDs: entry.PodUIDs, CDIDevices: entry.CDIDevices, }) } oldcheckpoint := &DRAManagerCheckpointWithoutResourceHandles{ Version: checkpointVersion, Entries: entries, Checksum: 0, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 18 15:23:10 UTC 2023 - 4.1K 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)