- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for podKeys (0.26 sec)
-
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/scheduler/framework/types.go
// String returns representation of human readable format of this NodeInfo. func (n *NodeInfo) String() string { podKeys := make([]string, len(n.Pods)) for i, p := range n.Pods { podKeys[i] = p.Pod.Name } return fmt.Sprintf("&NodeInfo{Pods:%v, RequestedResource:%#v, NonZeroRequest: %#v, UsedPort: %#v, AllocatableResource:%#v}", podKeys, n.Requested, n.NonZeroRequested, n.UsedPorts, n.Allocatable) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 19:28:17 UTC 2024 - 36.7K 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 (1) -
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/scheduler/framework/plugins/nodevolumelimits/csi_test.go
}) } } func TestCSILimitsQHint(t *testing.T) { podEbs := st.MakePod().PVC("csi-ebs.csi.aws.com-2") tests := []struct { newPod *v1.Pod deletedPod *v1.Pod deletedPodNotScheduled bool test string wantQHint framework.QueueingHint }{ { newPod: podEbs.Obj(), deletedPod: st.MakePod().PVC("placeholder").Obj(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 18:07:11 UTC 2024 - 28.6K 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/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)