Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for podKeys (0.44 sec)

  1. pkg/controller/replicaset/replica_set_test.go

    		},
    	}
    
    	for _, test := range tests {
    		podKeys := getPodKeys(test.pods)
    		if len(podKeys) != len(test.expectedPodKeys) {
    			t.Errorf("%s: unexpected keys for pods to delete, expected %v, got %v", test.name, test.expectedPodKeys, podKeys)
    		}
    		for i := 0; i < len(podKeys); i++ {
    			if podKeys[i] != test.expectedPodKeys[i] {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 69.2K bytes
    - Viewed (0)
  2. pkg/controller/podautoscaler/horizontal.go

    	a.hpaSelectorsMux.Lock()
    	defer a.hpaSelectorsMux.Unlock()
    
    	hpas := map[selectors.Key]struct{}{}
    	for _, p := range pods {
    		podKey := selectors.Key{Name: p.Name, Namespace: p.Namespace}
    		a.hpaSelectors.Put(podKey, p.Labels)
    
    		selectingHpas, ok := a.hpaSelectors.ReverseSelect(podKey)
    		if !ok {
    			continue
    		}
    		for _, hpa := range selectingHpas {
    			hpas[hpa] = struct{}{}
    		}
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 63.6K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/storage/testing/watcher_tests.go

    				pod := &example.Pod{
    					ObjectMeta: metav1.ObjectMeta{
    						Name:      fmt.Sprintf("foo-%d", i),
    						Namespace: "test-ns",
    					},
    				}
    				podKey := computePodKey(pod)
    				if err := store.Create(ctx, podKey, pod, out, 0); err != nil {
    					errc <- fmt.Errorf("failed to create pod %v: %v", pod, err)
    					return
    				}
    				time.Sleep(10 * time.Millisecond)
    			}
    		}
    	}()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 63.8K bytes
    - Viewed (0)
  4. pkg/scheduler/internal/queue/scheduling_queue.go

    // is found in the map. It returns nil otherwise.
    func (u *UnschedulablePods) get(pod *v1.Pod) *framework.QueuedPodInfo {
    	podKey := u.keyFunc(pod)
    	if pInfo, exists := u.podInfoMap[podKey]; exists {
    		return pInfo
    	}
    	return nil
    }
    
    // clear removes all the entries from the unschedulable podInfoMap.
    func (u *UnschedulablePods) clear() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 61.4K bytes
    - Viewed (0)
Back to top