- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 345 for podMap (0.36 sec)
-
pkg/controller/deployment/recreate_test.go
rs.UID = types.UID(uid) return rs } func podMapWithUIDs(uids []string) map[types.UID][]*v1.Pod { podMap := make(map[types.UID][]*v1.Pod) for _, uid := range uids { podMap[types.UID(uid)] = []*v1.Pod{ { /* supposedly a pod */ }, { /* supposedly another pod pod */ }, } } return podMap
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 08 09:10:50 UTC 2023 - 5.9K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/scope_test.go
scope := scope{} scope.podMap = containermap.NewContainerMap() scope.podTopologyHints = podTopologyHints{} for _, tc := range testCases { scope.podMap.Add(string(tc.podUID), tc.name, tc.containerID) scope.podTopologyHints[string(tc.podUID)] = make(map[string]TopologyHint) scope.podTopologyHints[string(tc.podUID)][tc.name] = TopologyHint{} len1 = len(scope.podMap) lenHints1 = len(scope.podTopologyHints)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 10 11:44:15 UTC 2021 - 3.3K bytes - Viewed (0) -
pkg/controller/deployment/recreate.go
func oldPodsRunning(newRS *apps.ReplicaSet, oldRSs []*apps.ReplicaSet, podMap map[types.UID][]*v1.Pod) bool { if oldPods := util.GetActualReplicaCountForReplicaSets(oldRSs); oldPods > 0 { return true } for rsUID, podList := range podMap { // If the pods belong to the new ReplicaSet, ignore. if newRS != nil && newRS.UID == rsUID { continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 13 20:32:13 UTC 2021 - 4.2K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/scope.go
// Get the podUID and containerName associated with the containerID to be removed and remove it podUIDString, containerName, err := s.podMap.GetContainerRef(containerID) if err != nil { return nil } s.podMap.RemoveByContainerID(containerID) // In cases where a container has been restarted, it's possible that the same podUID and
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 14 14:44:24 UTC 2023 - 5K bytes - Viewed (0) -
cni/pkg/repair/repair_test.go
} func makePodLabelMap(pods []*corev1.Pod) (podmap map[string]string) { podmap = map[string]string{} for _, pod := range pods { podmap[pod.Name] = "" for key, value := range pod.Labels { podmap[pod.Name] = strings.Join([]string{podmap[pod.Name], fmt.Sprintf("%s=%s", key, value)}, ",") } podmap[pod.Name] = strings.Trim(podmap[pod.Name], " ,") } return }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 24 03:31:28 UTC 2023 - 10.6K bytes - Viewed (0) -
pkg/controller/deployment/deployment_controller.go
controllerRef := metav1.GetControllerOf(pod) if controllerRef == nil { continue } // Only append if we care about this UID. if _, ok := podMap[controllerRef.UID]; ok { podMap[controllerRef.UID] = append(podMap[controllerRef.UID], pod) } } return podMap, nil } // syncDeployment will sync the deployment with the given key. // This function is not meant to be invoked concurrently with the same key.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.2K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/scope_none.go
// NewNoneScope returns a none scope. func NewNoneScope() Scope { return &noneScope{ scope{ name: noneTopologyScope, podTopologyHints: podTopologyHints{}, policy: NewNonePolicy(), podMap: containermap.NewContainerMap(), }, } } func (s *noneScope) Admit(pod *v1.Pod) lifecycle.PodAdmitResult { return s.admitPolicyNone(pod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 14 14:44:24 UTC 2023 - 1.2K bytes - Viewed (0) -
pkg/controller/deployment/deployment_controller_test.go
} if got, want := len(podMap[rs1.UID]), 2; got != want { t.Errorf("len(podMap[rs1]) = %v, want %v", got, want) } expect := map[string]struct{}{"rs1-pod": {}, "pod4": {}} for _, pod := range podMap[rs1.UID] { if _, ok := expect[pod.Name]; !ok { t.Errorf("unexpected pod name for rs1: %s", pod.Name) } } if got, want := len(podMap[rs2.UID]), 1; got != want { t.Errorf("len(podMap[rs2]) = %v, want %v", got, want)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.5K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/scope_container.go
func NewContainerScope(policy Policy) Scope { return &containerScope{ scope{ name: containerTopologyScope, podTopologyHints: podTopologyHints{}, policy: policy, podMap: containermap.NewContainerMap(), }, } } func (s *containerScope) Admit(pod *v1.Pod) lifecycle.PodAdmitResult { for _, container := range append(pod.Spec.InitContainers, pod.Spec.Containers...) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 14 14:44:24 UTC 2023 - 2.9K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/scope_pod.go
// NewPodScope returns a pod scope. func NewPodScope(policy Policy) Scope { return &podScope{ scope{ name: podTopologyScope, podTopologyHints: podTopologyHints{}, policy: policy, podMap: containermap.NewContainerMap(), }, } } func (s *podScope) Admit(pod *v1.Pod) lifecycle.PodAdmitResult { bestHint, admit := s.calculateAffinity(pod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 14 14:44:24 UTC 2023 - 2.6K bytes - Viewed (0)