lifecycle

Documentation

Index

• Variables
• func AlreadyAssigned(runtimeInfo base.RuntimeInfoInterface, node v1.Node) (assigned bool)
• func AssignDatasetToNodes(runtimeInfo base.RuntimeInfoInterface, dataset *datav1alpha1.Dataset, ...) (currentScheduleNum int32, err error)
• func CanbeAssigned(runtimeInfo base.RuntimeInfoInterface, node v1.Node) bool
• func DecreaseDatasetNum(toUpdate *v1.Node, runtimeInfo base.RuntimeInfoInterface, ...) error
• func LabelCacheNode(nodeToLabel v1.Node, runtimeInfo base.RuntimeInfoInterface, ...) (err error)

Variables

var SchedulerMutex = sync.Mutex{}

TODO: move this to some Scheduler-like struct SchedulerMutex is a mutex to protect the scheduling process from race condition

Functions

func AlreadyAssigned

func AlreadyAssigned(runtimeInfo base.RuntimeInfoInterface, node v1.Node) (assigned bool)

AlreadyAssigned checks if the node is already assigned the runtime engine If runtime engine cached dataset is exclusive, will check if any runtime engine already assigned the runtime engine

func AssignDatasetToNodes

func AssignDatasetToNodes(runtimeInfo base.RuntimeInfoInterface,
	dataset *datav1alpha1.Dataset,
	runtimeClient client.Client,
	desiredNum int32) (currentScheduleNum int32, err error)

func CanbeAssigned

func CanbeAssigned(runtimeInfo base.RuntimeInfoInterface, node v1.Node) bool

CanbeAssigned checks if the node is already assigned the runtime engine

func DecreaseDatasetNum

func DecreaseDatasetNum(toUpdate *v1.Node, runtimeInfo base.RuntimeInfoInterface, labelsToModify *common.LabelsToModify) error

DecreaseDatasetNum deletes the datasetNum label or updates the number of the dataset in the specific node.

func LabelCacheNode

func LabelCacheNode(nodeToLabel v1.Node, runtimeInfo base.RuntimeInfoInterface, client client.Client) (err error)

LabelCacheNode adds labels on a selected node to indicate the node is scheduled with corresponding runtime