- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 102 for podKey (0.13 sec)
-
pkg/controller/volume/ephemeral/controller_test.go
expectedMetrics: expectedMetrics{1, 0}, }, { name: "no-such-pod", podKey: podKey(testPodWithEphemeral), }, { name: "pod-deleted", pods: func() []*v1.Pod { deleted := metav1.Now() pods := []*v1.Pod{testPodWithEphemeral.DeepCopy()} pods[0].DeletionTimestamp = &deleted return pods }(), podKey: podKey(testPodWithEphemeral), }, { name: "no-volumes",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 8.5K bytes - Viewed (0) -
pkg/controller/resourceclaim/controller_test.go
pods: []*v1.Pod{testPodWithResource}, templates: nil, key: podKey(testPodWithResource), expectedError: true, }, { name: "find-existing-claim-by-label", pods: []*v1.Pod{testPodWithResource}, key: podKey(testPodWithResource), claims: []*resourcev1alpha2.ResourceClaim{generatedTestClaim},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 08:56:16 UTC 2024 - 28.2K bytes - Viewed (0) -
tools/bug-report/pkg/cluster/cluster.go
if c.Name == inject.ProxyContainerName { out.insertContainer(p.Namespace, deployment, p.Name, c.Name) } } } out.Labels[PodKey(p.Namespace, p.Name)] = p.Labels out.Annotations[PodKey(p.Namespace, p.Name)] = p.Annotations out.Pod[PodKey(p.Namespace, p.Name)] = &pods.Items[i] } return out, nil } // Resources defines a tree of cluster resource names. type Resources struct {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Dec 14 02:11:31 UTC 2023 - 10.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/pod.go
return pmap } // deleteIP returns true if the pod and ip are really deleted. func (pc *PodCache) deleteIP(ip string, podKey types.NamespacedName) bool { pc.Lock() defer pc.Unlock() if pc.podsByIP[ip].Contains(podKey) { sets.DeleteCleanupLast(pc.podsByIP, ip, podKey) delete(pc.IPByPods, podKey) return true } return false } func (pc *PodCache) addPod(pod *v1.Pod, ip string, key types.NamespacedName) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 10.8K bytes - Viewed (0) -
pkg/scheduler/internal/cache/cache.go
logger.V(5).Info("Could not expire cache for pod as binding is still in progress", "podKey", key, "pod", klog.KObj(ps.pod)) continue } if cache.ttl != 0 && now.After(*ps.deadline) { logger.Info("Pod expired", "podKey", key, "pod", klog.KObj(ps.pod)) if err := cache.removePod(logger, ps.pod); err != nil { logger.Error(err, "ExpirePod failed", "podKey", key, "pod", klog.KObj(ps.pod)) } } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 24 09:56:48 UTC 2023 - 24.9K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set.go
} return controller.ActivePodsWithRanks{Pods: podsToRank, Rank: ranks, Now: metav1.Now()} } func getPodKeys(pods []*v1.Pod) []string { podKeys := make([]string, 0, len(pods)) for _, pod := range pods { podKeys = append(podKeys, controller.PodKey(pod)) } return podKeys
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.2K bytes - Viewed (0) -
pkg/controller/volume/ephemeral/controller.go
return nil } logger.V(5).Info("Error getting pod from informer", "pod", klog.KObj(pod), "podUID", pod.UID, "err", err) return err } // Ignore pods which are already getting deleted. if pod.DeletionTimestamp != nil { logger.V(5).Info("Ephemeral: nothing to do for pod, it is marked for deletion", "podKey", key) return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.2K bytes - Viewed (0) -
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) -
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 (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)