util

Jun 11, 2022

Changes in this version

+ func CalculateAllocatedTaskNum(job *api.JobInfo) int

Mar 15, 2022

Changes in this version

+ func GetAllocatedResource(job *api.JobInfo) *api.Resource

+ func GetInqueueResource(job *api.JobInfo, allocated *api.Resource) *api.Resource

Sep 18, 2021

Changes in this version

+ func NormalizeScore(maxPriority int64, reverse bool, scores map[string]int64)

May 26, 2021

Changes in this version

+ type PodFilter func(*v1.Pod) bool

+ type PodsLister interface

+ FilteredList func(podFilter PodFilter, selector labels.Selector) ([]*v1.Pod, error)

+ List func(labels.Selector) ([]*v1.Pod, error)

Feb 23, 2021

Changes in this version

+ const Abstain

+ const Permit

+ const Reject

type PodLister

+ func NewPodListerFromNode(ssn *framework.Session) *PodLister

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