lifecycle

package
v1.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 28, 2024 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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 CanbeAssigned

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

CanbeAssigned checks if the node is already assigned the runtime engine

func CheckIfRuntimeInNode added in v0.7.0

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

CheckIfRuntimeInNode checks if the the runtime on this node

func DecreaseDatasetNum added in v0.6.0

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

func UnlabelCacheNode added in v0.7.0

func UnlabelCacheNode(node v1.Node, runtimeInfo base.RuntimeInfoInterface, client client.Client) (err error)

UnlabelCacheNode remove labels on a selected node to indicate the node doesn't have the cache for

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL