Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 345 for podMap (0.36 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top