Versions in this module Expand all Collapse all v0 v0.3.0 Feb 21, 2020 Changes in this version + func GenerateNodeMapAndSlice(nodes map[string]*api.NodeInfo) (map[string]*cache.NodeInfo, []*v1.Node) + func HaveAffinity(pod *v1.Pod) bool + type CachedNodeInfo struct + Session *framework.Session + func (c *CachedNodeInfo) GetNodeInfo(name string) (*v1.Node, error) + type NodeLister struct + Session *framework.Session + func (nl *NodeLister) List() ([]*v1.Node, error) + type PodAffinityLister struct + func (pal *PodAffinityLister) FilteredList(podFilter algorithm.PodFilter, selector labels.Selector) ([]*v1.Pod, error) + func (pal *PodAffinityLister) List(selector labels.Selector) ([]*v1.Pod, error) + type PodLister struct + CachedPods map[api.TaskID]*v1.Pod + Session *framework.Session + TaskWithAffinity map[api.TaskID]*api.TaskInfo + Tasks map[api.TaskID]*api.TaskInfo + func NewPodLister(ssn *framework.Session) *PodLister + func (pl *PodLister) AffinityFilteredList(podFilter algorithm.PodFilter, selector labels.Selector) ([]*v1.Pod, error) + func (pl *PodLister) AffinityLister() *PodAffinityLister + func (pl *PodLister) FilteredList(podFilter algorithm.PodFilter, selector labels.Selector) ([]*v1.Pod, error) + func (pl *PodLister) GetPod(task *api.TaskInfo) *v1.Pod + func (pl *PodLister) List(selector labels.Selector) ([]*v1.Pod, error) + func (pl *PodLister) UpdateTask(task *api.TaskInfo, nodeName string) *v1.Pod
Go to main page