Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 116 for UIDs (0.04 sec)

  1. pkg/controller/job/tracking_utils.go

    	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
    		}
    	}
    	uids.Lock()
    	uids.set.Insert(deletedKeys...)
    	uids.Unlock()
    	return nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 14 05:40:02 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  2. pkg/controller/job/tracking_utils_test.go

    	for i, err := range errs {
    		if err != nil {
    			t.Errorf("Failed adding first round of UIDs for job %s: %v", tracks[i].job, err)
    		}
    	}
    
    	for _, track := range tracks {
    		uids := expectations.getSet(track.job)
    		if uids == nil {
    			t.Errorf("Set of UIDs is empty for job %s", track.job)
    		} else if diff := cmp.Diff(track.firstRound, sets.List(uids.set)); diff != "" {
    			t.Errorf("Unexpected keys for job %s (-want,+got):\n%s", track.job, diff)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 14 05:40:02 UTC 2023
    - 5.9K bytes
    - Viewed (0)
  3. pkg/controller/garbagecollector/dump_test.go

    		name        string
    		uidToNode   map[types.UID]*node
    		uids        []types.UID
    		expectNodes []*dotVertex
    		expectEdges []dotEdge
    	}{
    		{
    			name: "simple",
    			uidToNode: map[types.UID]*node{
    				types.UID("alpha"):   alphaNode(),
    				types.UID("bravo"):   bravoNode(),
    				types.UID("charlie"): charlieNode(),
    			},
    			uids: []types.UID{types.UID("bravo")},
    			expectNodes: []*dotVertex{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 14 00:05:53 UTC 2023
    - 11.2K bytes
    - Viewed (0)
  4. pkg/controller/garbagecollector/dump.go

    }
    
    func (m *concurrentUIDToNode) ToDOTNodesAndEdgesForObj(uids ...types.UID) ([]*dotVertex, []dotEdge) {
    	m.uidToNodeLock.Lock()
    	defer m.uidToNodeLock.Unlock()
    
    	return toDOTNodesAndEdgesForObj(m.uidToNode, uids...)
    }
    
    func toDOTNodesAndEdgesForObj(uidToNode map[types.UID]*node, uids ...types.UID) ([]*dotVertex, []dotEdge) {
    	uidsToCheck := append([]types.UID{}, uids...)
    	interestingNodes := map[types.UID]*node{}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Sep 23 17:12:33 UTC 2022
    - 9.5K bytes
    - Viewed (0)
  5. cmd/local-locker.go

    				lris, ok := l.lockMap[resource]
    				if !ok {
    					continue
    				}
    				// Collect uids, so we don't mutate while we delete
    				uids := make([]string, 0, len(lris))
    				for _, lri := range lris {
    					uids = append(uids, lri.UID)
    				}
    
    				// Delete collected uids:
    				for _, uid := range uids {
    					lris, ok := l.lockMap[resource]
    					if !ok {
    						// Just to be safe, delete uuids.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  6. cmd/kubeadm/app/util/users/users_linux_test.go

    		groups         []*entry
    		usersToCreate  []*entry
    		groupsToCreate []*entry
    		uids           []int64
    		gids           []int64
    		expectedUsers  []*entry
    		expectedGroups []*entry
    		expectedError  bool
    	}{
    		{
    			name: "not enough UIDs",
    			usersToCreate: []*entry{
    				{name: "foo"},
    				{name: "bar"},
    			},
    			uids:          []int64{100},
    			expectedError: true,
    		},
    		{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Feb 01 05:59:41 UTC 2022
    - 16.3K bytes
    - Viewed (0)
  7. pkg/kubelet/userns/userns_manager.go

    			return nil, err
    		}
    	} else {
    		userNs, err = m.createUserNs(pod)
    		if err != nil {
    			return nil, err
    		}
    	}
    
    	var uids []*runtimeapi.IDMapping
    	var gids []*runtimeapi.IDMapping
    
    	for _, u := range userNs.UIDMappings {
    		uids = append(uids, &runtimeapi.IDMapping{
    			HostId:      u.HostId,
    			ContainerId: u.ContainerId,
    			Length:      u.Length,
    		})
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apimachinery/pkg/types/uid.go

    */
    
    package types
    
    // UID is a type that holds unique ID values, including UUIDs.  Because we
    // don't ONLY use UUIDs, this is an alias to string.  Being a type captures
    // intent and helps make sure that UIDs and names do not get conflated.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jan 11 14:09:48 UTC 2017
    - 825 bytes
    - Viewed (0)
  9. pkg/kubelet/pod/pod_manager.go

    	//
    	// All public-facing functions should perform this translation for UIDs
    	// because user may provide a mirror pod UID, which is not recognized by
    	// internal Kubelet functions.
    	TranslatePodUID(uid types.UID) kubetypes.ResolvedPodUID
    	// GetUIDTranslations returns the mappings of static pod UIDs to mirror pod
    	// UIDs and mirror pod UIDs to static pod UIDs.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:00 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  10. 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)
Back to top