Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for waitingPods (0.21 sec)

  1. pkg/scheduler/internal/cache/debugger/comparer.go

    		cached = append(cached, nodeName)
    	}
    
    	return compareStrings(actual, cached)
    }
    
    // ComparePods compares actual pods with cached pods.
    func (c *CacheComparer) ComparePods(pods, waitingPods []*v1.Pod, nodeinfos map[string]*framework.NodeInfo) (missed, redundant []string) {
    	actual := []string{}
    	for _, pod := range pods {
    		actual = append(actual, string(pod.UID))
    	}
    
    	cached := []string{}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 29 05:26:32 UTC 2023
    - 3.5K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/runtime/waiting_pods_map.go

    	for _, v := range m.pods {
    		callback(v)
    	}
    }
    
    // waitingPod represents a pod waiting in the permit phase.
    type waitingPod struct {
    	pod            *v1.Pod
    	pendingPlugins map[string]*time.Timer
    	s              chan *framework.Status
    	mu             sync.RWMutex
    }
    
    var _ framework.WaitingPod = &waitingPod{}
    
    // newWaitingPod returns a new waitingPod instance.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 4.5K bytes
    - Viewed (0)
Back to top