Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 167 for uids (0.16 sec)

  1. pkg/kubelet/userns/userns_manager.go

    			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,
    		})
    	}
    	for _, g := range userNs.GIDMappings {
    		gids = append(gids, &runtimeapi.IDMapping{
    			HostId:      g.HostId,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  2. cmd/local-locker.go

    		defer l.mutex.Unlock()
    		if len(args.UID) == 0 {
    			for _, resource := range args.Resources {
    				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 {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  3. cmd/kubeadm/app/util/users/users_linux.go

    // and assigns UIDs and GIDs to the users and groups to be created based on a list of provided UIDs and GIDs.
    // Returns an error if not enough UIDs or GIDs are passed. It does not perform any other validation.
    func assignUserAndGroupIDs(groups, usersToCreate, groupsToCreate []*entry, uids, gids []int64) error {
    	if len(gids) < len(groupsToCreate) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Oct 25 16:35:10 UTC 2023
    - 20.7K bytes
    - Viewed (0)
  4. pkg/kubelet/pod/pod_manager.go

    	// TranslatePodUID returns the actual UID of a pod. If the UID belongs to
    	// a mirror pod, returns the UID of its static pod. Otherwise, returns the
    	// original UID.
    	//
    	// 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
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:00 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  5. pkg/kubelet/cm/dra/state/state_checkpoint.go

    	DriverName string
    
    	// ClassName is a resource class of the claim
    	ClassName string
    
    	// ClaimUID is an UID of the resource claim
    	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]
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 03 13:23:27 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  6. pkg/controller/deployment/recreate_test.go

    			}
    		})
    	}
    }
    
    func rsWithUID(uid string) *apps.ReplicaSet {
    	d := newDeployment("foo", 1, nil, nil, nil, map[string]string{"foo": "bar"})
    	rs := newReplicaSet(d, fmt.Sprintf("foo-%s", uid), 0)
    	rs.UID = types.UID(uid)
    	return rs
    }
    
    func podMapWithUIDs(uids []string) map[types.UID][]*v1.Pod {
    	podMap := make(map[types.UID][]*v1.Pod)
    	for _, uid := range uids {
    		podMap[types.UID(uid)] = []*v1.Pod{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Sep 08 09:10:50 UTC 2023
    - 5.9K bytes
    - Viewed (0)
  7. cni/pkg/nodeagent/podcgroupns_test.go

    	n := NewPodNetnsProcFinder(fakeFs())
    	pod := &corev1.Pod{ObjectMeta: metav1.ObjectMeta{
    		Name:      "foo",
    		Namespace: "bar",
    		UID:       types.UID("863b91d4-4b68-4efa-917f-4b560e3e86aa"),
    	}}
    	podUIDNetns, err := n.FindNetnsForPods(map[types.UID]*corev1.Pod{
    		pod.UID: pod,
    	})
    	if err != nil {
    		panic(err)
    	}
    	defer podUIDNetns.Close()
    
    	if len(podUIDNetns) == 0 {
    		t.Fatal("expected to find pod netns")
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Apr 12 21:47:31 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  8. common-protos/k8s.io/api/batch/v1/generated.proto

    }
    
    // UncountedTerminatedPods holds UIDs of Pods that have terminated but haven't
    // been accounted in Job status counters.
    message UncountedTerminatedPods {
      // succeeded holds UIDs of succeeded Pods.
      // +listType=set
      // +optional
      repeated string succeeded = 1;
    
      // failed holds UIDs of failed Pods.
      // +listType=set
      // +optional
      repeated string failed = 2;
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 21.1K bytes
    - Viewed (0)
  9. pkg/kubelet/pod_workers_test.go

    	}
    	for _, uid := range uids {
    		if _, ok := w.holds[uid]; !ok {
    			w.holds[uid] = make(chan struct{})
    		}
    	}
    }
    
    func (w *timeIncrementingWorkers) ReleaseWorkers(uids ...types.UID) {
    	w.lock.Lock()
    	defer w.lock.Unlock()
    	w.ReleaseWorkersUnderLock(uids...)
    }
    
    func (w *timeIncrementingWorkers) ReleaseWorkersUnderLock(uids ...types.UID) {
    	for _, uid := range uids {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 75.6K bytes
    - Viewed (0)
  10. pkg/controller/controller_utils.go

    	u.uidStoreLock.Lock()
    	defer u.uidStoreLock.Unlock()
    
    	uids := u.GetUIDs(rcKey)
    	if uids != nil && uids.Has(deleteKey) {
    		logger.V(4).Info("Controller received delete for pod", "controller", rcKey, "key", deleteKey)
    		u.ControllerExpectationsInterface.DeletionObserved(logger, rcKey)
    		uids.Delete(deleteKey)
    	}
    }
    
    // DeleteExpectations deletes the UID set and invokes DeleteExpectations on the
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 12 15:34:44 UTC 2024
    - 47.6K bytes
    - Viewed (0)
Back to top