- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for podKey (0.1 sec)
-
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) -
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) -
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) -
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) -
pkg/kubelet/volumemanager/populator/desired_state_of_world_populator_test.go
podName := util.GetUniquePodName(pod) //let the pod be terminated podGet, exist := dswp.podManager.(mutablePodManager).GetPodByName(pod.Namespace, pod.Name) if !exist { t.Fatalf("Failed to get pod by pod name: %s and namespace: %s", pod.Name, pod.Namespace) } podGet.Status.Phase = v1.PodFailed dswp.podManager.(mutablePodManager).RemovePod(pod) dswp.findAndRemoveDeletedPods()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 51.4K bytes - Viewed (0) -
pkg/kubelet/stats/cri_stats_provider_test.go
assert := assert.New(t) assert.NoError(err) assert.Equal(4, len(stats)) podStatsMap := make(map[statsapi.PodReference]statsapi.PodStats) for _, s := range stats { podStatsMap[s.PodRef] = s } p0 := podStatsMap[statsapi.PodReference{Name: "sandbox0-name", UID: "sandbox0-uid", Namespace: "sandbox0-ns"}] assert.Equal(sandbox0.CreatedAt, p0.StartTime.UnixNano()) assert.Equal(2, len(p0.Containers))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 54.5K bytes - Viewed (0) -
src/cmd/go/internal/modload/init.go
// actually selected. r := resolveReplacement(m) keep[modkey(r)] = true } }) if which == addBuildListZipSums { for _, m := range mg.BuildList() { r := resolveReplacement(m) if keepModSumsForZipSums { keep[modkey(r)] = true // we need the go version from the go.mod file to do anything useful with the zipfile } keep[r] = true
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 18:36:30 UTC 2024 - 69.8K bytes - Viewed (0) -
pkg/volume/testing/testing.go
return false } func (plugin *FakeFileVolumePlugin) SupportsSELinuxContextMount(spec *volume.Spec) (bool, error) { return false, nil } func (plugin *FakeFileVolumePlugin) NewMounter(spec *volume.Spec, podRef *v1.Pod, opts volume.VolumeOptions) (volume.Mounter, error) { return nil, nil } func (plugin *FakeFileVolumePlugin) NewUnmounter(name string, podUID types.UID) (volume.Unmounter, error) { return nil, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 12:32:15 UTC 2024 - 53.3K bytes - Viewed (0)