- Sort Score
- Result 10 results
- Languages All
Results 11 - 18 of 18 for podKeys (0.14 sec)
-
tools/bug-report/pkg/filter/filter.go
return false } if !match.MatchesGlobs(container, sp.Containers) { return false } if !match.MatchesGlobs(container, sp.Containers) { return false } key := cluster2.PodKey(namespace, pod) if !match.MatchesMap(sp.Labels, cluster.Labels[key]) { return false } if !match.MatchesMap(sp.Annotations, cluster.Annotations[key]) { return false } return true }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Oct 13 23:42:29 UTC 2022 - 3.9K bytes - Viewed (0) -
pkg/registry/core/pod/storage/storage.go
func (r *BindingREST) setPodHostAndAnnotations(ctx context.Context, podUID types.UID, podResourceVersion, podID, machine string, annotations map[string]string, dryRun bool) (finalPod *api.Pod, err error) { podKey, err := r.store.KeyFunc(ctx, podID) if err != nil { return nil, err } var preconditions *storage.Preconditions if podUID != "" || podResourceVersion != "" { preconditions = &storage.Preconditions{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 20 14:29:25 UTC 2023 - 13.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher_test.go
barThird := &example.Pod{ObjectMeta: metav1.ObjectMeta{Namespace: "third", Name: "bar"}} podKey := fmt.Sprintf("/pods/%s/%s", barThird.Namespace, barThird.Name) storedObj := &example.Pod{} err := store.Create(context.Background(), podKey, barThird, storedObj, 0) if err != nil { t.Errorf("failed to create object: %v", err) } })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 12.3K bytes - Viewed (1) -
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) -
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/controller/controller_utils.go
} } return filtered } // PodKey returns a key unique to the given pod within a cluster. // It's used so we consistently use the same key scheme in this module. // It does exactly what cache.MetaNamespaceKeyFunc would have done // except there's not possibility for error since we know the exact type. func PodKey(pod *v1.Pod) string { return fmt.Sprintf("%v/%v", pod.Namespace, pod.Name) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 12 15:34:44 UTC 2024 - 47.6K 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/controller/controller_utils_test.go
} rcPodNames := []string{} for i := range podList.Items { p := &podList.Items[i] p.Name = fmt.Sprintf("%v-%v", p.Name, rc.Name) rcPodNames = append(rcPodNames, PodKey(p)) } uidExp.ExpectDeletions(logger, rcKey, rcPodNames) return rcKey, rcPodNames } tests := []test{ {name: "Replication controller with 2 replicas", numReplicas: 2},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 39.4K bytes - Viewed (0)