lifecycle

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 LabelCacheNode ¶

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