Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for podUIDs (0.51 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top