Versions in this module Expand all Collapse all v0 v0.3.0 Feb 21, 2020 Changes in this version + func BuildNode(name string, alloc v1.ResourceList, labels map[string]string) *v1.Node + func BuildPod(namespace, name, nodename string, p v1.PodPhase, req v1.ResourceList, ...) *v1.Pod + func BuildResourceList(cpu string, memory string) v1.ResourceList + func BuildResourceListWithGPU(cpu string, memory string, GPU string) v1.ResourceList + func CalculateNumOfFeasibleNodesToFind(numAllNodes int32) (numNodes int32) + func GetNodeList(nodes map[string]*api.NodeInfo) []*api.NodeInfo + func PredicateNodes(task *api.TaskInfo, nodes []*api.NodeInfo, fn api.PredicateFn) ([]*api.NodeInfo, *api.FitErrors) + func PrioritizeNodes(task *api.TaskInfo, nodes []*api.NodeInfo, batchFn api.BatchNodeOrderFn, ...) map[float64][]*api.NodeInfo + func SelectBestNode(nodeScores map[float64][]*api.NodeInfo) *api.NodeInfo + func SortNodes(nodeScores map[float64][]*api.NodeInfo) []*api.NodeInfo + type FakeBinder struct + Binds map[string]string + Channel chan string + func (fb *FakeBinder) Bind(p *v1.Pod, hostname string) error + type FakeEvictor struct + Channel chan string + func (fe *FakeEvictor) Evict(p *v1.Pod) error + func (fe *FakeEvictor) Evicts() []string + type FakeStatusUpdater struct + func (ftsu *FakeStatusUpdater) UpdatePodCondition(pod *v1.Pod, podCondition *v1.PodCondition) (*v1.Pod, error) + func (ftsu *FakeStatusUpdater) UpdatePodGroup(pg *api.PodGroup) (*api.PodGroup, error) + type FakeVolumeBinder struct + func (fvb *FakeVolumeBinder) AllocateVolumes(task *api.TaskInfo, hostname string) error + func (fvb *FakeVolumeBinder) BindVolumes(task *api.TaskInfo) error + type PriorityQueue struct + func NewPriorityQueue(lessFn api.LessFn) *PriorityQueue + func (q *PriorityQueue) Empty() bool + func (q *PriorityQueue) Len() int + func (q *PriorityQueue) Pop() interface{} + func (q *PriorityQueue) Push(it interface{})
Go to main page