lifecycle

Documentation

Index

• Variables
• func CheckIfRuntimeInNode(node corev1.Node, runtimeInfo base.RuntimeInfoInterface) (found bool)
• func DecreaseDatasetNum(toUpdate *corev1.Node, runtimeInfo base.RuntimeInfoInterface, ...) error
• func SyncScheduleInfoToCacheNodes(runtimeInfo base.RuntimeInfoInterface, client client.Client) (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 CheckIfRuntimeInNode

func CheckIfRuntimeInNode(node corev1.Node, runtimeInfo base.RuntimeInfoInterface) (found bool)

CheckIfRuntimeInNode checks if the the runtime on this node

func DecreaseDatasetNum

func DecreaseDatasetNum(toUpdate *corev1.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 SyncScheduleInfoToCacheNodes

func SyncScheduleInfoToCacheNodes(runtimeInfo base.RuntimeInfoInterface, client client.Client) (err error)