scheduler

Documentation

Index

• func ConfigFromPath(path string) (*scheduler_config.KubeSchedulerConfiguration, error)
• func CreateNodeNameToInfoMap(pods []*apiv1.Pod, nodes []*apiv1.Node) map[string]*framework.NodeInfo
• func DeepCopyTemplateNode(nodeTemplate *framework.NodeInfo, suffix string) *framework.NodeInfo
• func GetBypassedSchedulersMap(bypassedSchedulers []string) map[string]bool
• func ResourceToResourceList(r *schedulerframework.Resource) apiv1.ResourceList

Functions

func ConfigFromPath

func ConfigFromPath(path string) (*scheduler_config.KubeSchedulerConfiguration, error)

ConfigFromPath loads scheduler config from a path. TODO(vadasambar): replace code to parse scheduler config with upstream function once https://github.com/kubernetes/kubernetes/pull/119057 is merged

func CreateNodeNameToInfoMap

func CreateNodeNameToInfoMap(pods []*apiv1.Pod, nodes []*apiv1.Node) map[string]*framework.NodeInfo

CreateNodeNameToInfoMap obtains a list of pods and pivots that list into a map where the keys are node names and the values are the aggregated information for that node. Pods waiting lower priority pods preemption (pod.Status.NominatedNodeName is set) are also added to list of pods for a node.

func DeepCopyTemplateNode

func DeepCopyTemplateNode(nodeTemplate *framework.NodeInfo, suffix string) *framework.NodeInfo

DeepCopyTemplateNode copies NodeInfo object used as a template. It changes names of UIDs of both node and pods running on it, so that copies can be used to represent multiple nodes.

func GetBypassedSchedulersMap

func GetBypassedSchedulersMap(bypassedSchedulers []string) map[string]bool

GetBypassedSchedulersMap returns a map of scheduler names that should be bypassed as keys, and values are set to true Also sets "" (empty string) to true if default scheduler is bypassed

func ResourceToResourceList

func ResourceToResourceList(r *schedulerframework.Resource) apiv1.ResourceList

ResourceToResourceList returns a resource list of the resource.