Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for podKeys (1.8 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
Back to top