Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 86 for uids (0.04 sec)

  1. cni/pkg/repair/repaircontroller.go

    	// Instead, we track which UIDs we repaired and skip them if already repaired.
    	//
    	// An alternative would be to write something to the Pod (status, annotation, etc).
    	// However, this requires elevated privileges we want to avoid
    	if uid, f := c.repairedPods[key]; f {
    		if uid == pod.UID {
    			log.Debugf("Skipping pod, already repaired")
    		} else {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat Feb 10 00:31:55 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/collect/Ordering.java

        private final ConcurrentMap<Object, Integer> uids =
            Platform.tryWeakKeys(new MapMaker()).makeMap();
    
        private Integer getUid(Object obj) {
          Integer uid = uids.get(obj);
          if (uid == null) {
            // One or more integer values could be skipped in the event of a race
            // to generate a UID for the same object from multiple threads, but
            // that shouldn't be a problem.
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue May 28 18:11:09 UTC 2024
    - 39.4K bytes
    - Viewed (0)
  3. guava/src/com/google/common/collect/Ordering.java

        private final ConcurrentMap<Object, Integer> uids =
            Platform.tryWeakKeys(new MapMaker()).makeMap();
    
        private Integer getUid(Object obj) {
          Integer uid = uids.get(obj);
          if (uid == null) {
            // One or more integer values could be skipped in the event of a race
            // to generate a UID for the same object from multiple threads, but
            // that shouldn't be a problem.
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue May 28 18:11:09 UTC 2024
    - 39.4K bytes
    - Viewed (0)
  4. pkg/scheduler/extender.go

    	metaPod *extenderv1.MetaPod,
    	nodeInfo *framework.NodeInfo) (*v1.Pod, error) {
    	for _, p := range nodeInfo.Pods {
    		if string(p.Pod.UID) == metaPod.UID {
    			return p.Pod, nil
    		}
    	}
    	return nil, fmt.Errorf("extender: %v claims to preempt pod (UID: %v) on node: %v, but the pod is not found on that node",
    		h.extenderURL, metaPod, nodeInfo.Node().Name)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 19:07:19 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/endpoints/filters/impersonation_test.go

    		{
    			name: "allowed-user-impersonation-with-uid",
    			user: &user.DefaultInfo{
    				Name: "dev",
    				Groups: []string{
    					"everything-impersonater",
    				},
    			},
    			impersonationUser: "tester",
    			impersonationUid:  "some-uid",
    			expectedUser: &user.DefaultInfo{
    				Name:   "tester",
    				Groups: []string{"system:authenticated"},
    				Extra:  map[string][]string{},
    				UID:    "some-uid",
    			},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 06 17:13:16 UTC 2021
    - 17.2K bytes
    - Viewed (0)
  6. pkg/kubelet/kuberuntime/kuberuntime_container_linux.go

    				mount.UidMappings = cl.SecurityContext.NamespaceOptions.UsernsOptions.Uids
    				mount.GidMappings = cl.SecurityContext.NamespaceOptions.UsernsOptions.Gids
    			}
    		}
    	}
    	return nil
    }
    
    // generateLinuxContainerConfig generates linux container config for kubelet runtime v1.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 17.2K bytes
    - Viewed (0)
  7. pkg/workloadapi/workload.proto

      // two Workloads with the following UIDs:
      // - cluster1/networking.istio.io/v1alpha3/ServiceEntry/default/external-svc/endpoint1
      // - cluster1/networking.istio.io/v1alpha3/ServiceEntry/default/external-svc/endpoint2
      //
      // For VMs and other workloads other formats are also supported; for example,
      // a single UID string: "0ae5c03d-5fb3-4eb9-9de8-2bd4b51606ba"
      string uid = 20;
      // Name represents the name for the workload.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 12 18:02:35 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  8. pkg/controller/replicaset/replica_set.go

    		if err != nil {
    			return nil, err
    		}
    		if fresh.UID != rs.UID {
    			return nil, fmt.Errorf("original %v %v/%v is gone: got uid %v, wanted %v", rsc.Kind, rs.Namespace, rs.Name, fresh.UID, rs.UID)
    		}
    		return fresh, nil
    	})
    	cm := controller.NewPodControllerRefManager(rsc.podControl, rs, selector, rsc.GroupVersionKind, canAdoptFunc)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  9. cni/pkg/nodeagent/net.go

    func (s *NetServer) buildZtunnelSnapshot(ambientPodUIDs map[types.UID]*corev1.Pod) error {
    	// first add all the pods as empty:
    	for uid := range ambientPodUIDs {
    		s.currentPodSnapshot.Ensure(string(uid))
    	}
    
    	// populate full pod snapshot from cgroups
    	return s.scanProcForPodsAndCache(ambientPodUIDs)
    }
    
    func (s *NetServer) scanProcForPodsAndCache(pods map[types.UID]*corev1.Pod) error {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 05:10:23 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/rest.go

    // sharing the same UID but different fields. Nor do we know what might break.
    // In the future we may just dedup/reject owner references with the same UID.
    func dedupOwnerReferences(refs []metav1.OwnerReference) ([]metav1.OwnerReference, []string) {
    	var result []metav1.OwnerReference
    	var duplicates []string
    	seen := make(map[types.UID]struct{})
    	for _, ref := range refs {
    		_, ok := seen[ref.UID]
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 08 21:44:00 UTC 2023
    - 17K bytes
    - Viewed (0)
Back to top