- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for podUIDs (0.51 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/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) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 07 05:59:34 UTC 2023 - 2.7K bytes - Viewed (0) -
pkg/controller/job/tracking_utils.go
func (u *uidTrackingExpectations) expectFinalizersRemoved(logger klog.Logger, jobKey string, deletedKeys []string) error { logger.V(4).Info("Expecting tracking finalizers removed", "key", jobKey, "podUIDs", deletedKeys) uids := u.getSet(jobKey) if uids == nil { uids = &uidSet{ key: jobKey, set: sets.New[string](), } if err := u.store.Add(uids); err != nil { return err } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 14 05:40:02 UTC 2023 - 4.3K bytes - Viewed (0)