Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for uid (0.17 sec)

  1. 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 {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 12.2K bytes
    - Viewed (1)
  2. cni/pkg/nodeagent/net_test.go

    			Namespace: "bar",
    			UID:       "123",
    		},
    		Spec: corev1.PodSpec{ServiceAccountName: "sa"},
    	}
    
    	// this is usually called after add. so manually add the pod uid for now
    	fakens := newFakeNs(123)
    	closed := fakens.closed
    	workload := WorkloadInfo{
    		Workload: podToWorkload(pod),
    		Netns:    fakens,
    	}
    	fixture.podNsMap.UpsertPodCacheWithNetns(string(pod.UID), workload)
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 16.4K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/informers_test.go

    	NodeName = "testnode"
    
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    
    	pod := &corev1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "test",
    			Namespace: "test",
    			UID:       "1234",
    		},
    		Spec: corev1.PodSpec{
    			NodeName: NodeName,
    		},
    		Status: corev1.PodStatus{
    			PodIP: "11.1.1.12",
    		},
    	}
    	ns := &corev1.Namespace{
    		ObjectMeta: metav1.ObjectMeta{
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri May 03 19:29:42 GMT 2024
    - 15.8K bytes
    - Viewed (0)
  4. cmd/sts-handlers_test.go

    						},
    						ldapUserPolicyMappings: map[string][]string{
    							"uid=dillon,ou=people,ou=swengg,dc=min,dc=io": {"mypolicy"},
    							"uid=liza,ou=people,ou=swengg,dc=min,dc=io":   {"consoleAdmin"},
    						},
    						ldapGroupPolicyMappings: map[string][]string{
    							"cn=projectb,ou=groups,ou=swengg,dc=min,dc=io": {"mypolicy"},
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 15:50:16 GMT 2024
    - 85.7K bytes
    - Viewed (0)
  5. cmd/admin-handlers-users.go

    				return
    			}
    			userAccounts := make(map[string]madmin.AddOrUpdateUserReq)
    			for u, uid := range userIdentities {
    				userAccounts[u] = madmin.AddOrUpdateUserReq{
    					SecretKey: uid.Credentials.SecretKey,
    					Status: func() madmin.AccountStatus {
    						// Export current credential status
    						if uid.Credentials.Status == auth.AccountOff {
    							return madmin.AccountDisabled
    						}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 12:41:13 GMT 2024
    - 77.5K bytes
    - Viewed (0)
  6. cmd/admin-handlers.go

    	entry := &madmin.LockEntry{
    		Timestamp:  l.Timestamp,
    		Elapsed:    now.Sub(l.Timestamp),
    		Resource:   resource,
    		ServerList: []string{server},
    		Source:     l.Source,
    		Owner:      l.Owner,
    		ID:         l.UID,
    		Quorum:     l.Quorum,
    	}
    	if l.Writer {
    		entry.Type = "WRITE"
    	} else {
    		entry.Type = "READ"
    	}
    	return entry
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 29 17:39:04 GMT 2024
    - 97.8K bytes
    - Viewed (2)
Back to top