scheduler_maintainer

package
v0.0.0-...-6111fc0 Latest Latest
Warning

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

 Go to latest Published: Dec 2, 2024 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func IsSchedulerActive 

func IsSchedulerActive(scheduler *schedulerapi.Scheduler) bool

IsSchedulerActive checks whether schedulers is active

Types

type SchedulerMaintainer 

type SchedulerMaintainer struct {

	// TODO: support dynamic node partition type switching
	// NodePartitionType indicates the type of node partition (physical or logical)
	NodePartitionType string
	// contains filtered or unexported fields
}

TODO: figure out if we need a separate CRD for Node Partition

func NewSchedulerMaintainer 

func NewSchedulerMaintainer(crdClient crdclient.Interface, schedulerLister schedulerlister.SchedulerLister) *SchedulerMaintainer

NewSchedulerMaintainer creates a new SchedulerMaintainer struct object

func (*SchedulerMaintainer) ActivateScheduler 

func (maintainer *SchedulerMaintainer) ActivateScheduler(schedulerName string) error

ActivateScheduler moves schedulers from inactive queue to active queue

func (*SchedulerMaintainer) AddNMNodeToGodelSchedulerIfNotPresent 

func (maintainer *SchedulerMaintainer) AddNMNodeToGodelSchedulerIfNotPresent(nmNode *nodev1alpha1.NMNode) error

AddNMNodeToGodelSchedulerIfNotPresent adds NMNode to specific godel schedulers

func (*SchedulerMaintainer) AddNodeToGodelSchedulerIfNotPresent 

func (maintainer *SchedulerMaintainer) AddNodeToGodelSchedulerIfNotPresent(node *v1.Node) error

AddNodeToGodelSchedulerIfNotPresent adds node to specific godel schedulers

func (*SchedulerMaintainer) AddScheduler 

func (maintainer *SchedulerMaintainer) AddScheduler(scheduler *schedulerapi.Scheduler)

AddScheduler adds schedulers to maintainer cache

func (*SchedulerMaintainer) CleanupInActiveSchedulers 

func (maintainer *SchedulerMaintainer) CleanupInActiveSchedulers()

func (*SchedulerMaintainer) DeactivateScheduler 

func (maintainer *SchedulerMaintainer) DeactivateScheduler(schedulerName string) error

DeactivateScheduler moves schedulers from active queue to inactive queue

func (*SchedulerMaintainer) DeleteNMNodeFromGodelScheduler 

func (maintainer *SchedulerMaintainer) DeleteNMNodeFromGodelScheduler(nmNode *nodev1alpha1.NMNode) error

DeleteNMNodeFromGodelScheduler deletes nmnode from specific godel schedulers

func (*SchedulerMaintainer) DeleteNodeFromGodelScheduler 

func (maintainer *SchedulerMaintainer) DeleteNodeFromGodelScheduler(node *v1.Node) error

DeleteNodeFromGodelScheduler deletes node from specific godel schedulers

func (*SchedulerMaintainer) DeleteScheduler 

func (maintainer *SchedulerMaintainer) DeleteScheduler(scheduler *schedulerapi.Scheduler)

DeleteScheduler moves schedulers from active queue to inactive queue to trigger shuffle operation later

func (*SchedulerMaintainer) GetActiveSchedulers 

func (maintainer *SchedulerMaintainer) GetActiveSchedulers() []string

GetActiveSchedulers gets all active schedulers

func (*SchedulerMaintainer) GetEarliestInactiveCloneScheduler 

func (maintainer *SchedulerMaintainer) GetEarliestInactiveCloneScheduler() *sche.GodelScheduler

GetEarliestInactiveScheduler gets the earliest inactive schedulers

func (*SchedulerMaintainer) GetGeneralActiveSchedulerWithLeastNumberOfNodes 

func (maintainer *SchedulerMaintainer) GetGeneralActiveSchedulerWithLeastNumberOfNodes() *SchedulersWithLeastNumberOfNodes

GetGeneralActiveSchedulerWithLeastNumberOfNodes gets the schedulers with the least number of nodes from general active schedulers

func (*SchedulerMaintainer) GetInactiveSchedulers 

func (maintainer *SchedulerMaintainer) GetInactiveSchedulers() []string

GetInactiveSchedulers gets all inactive schedulers

func (*SchedulerMaintainer) GetNumberOfNodesFromActiveScheduler 

func (maintainer *SchedulerMaintainer) GetNumberOfNodesFromActiveScheduler(schedulerName string) int

GetNumberOfNodesFromActiveScheduler gets the number of nodes for general active schedulers

func (*SchedulerMaintainer) GetSchedulersWithMostAndLeastNumberOfNodes 

func (maintainer *SchedulerMaintainer) GetSchedulersWithMostAndLeastNumberOfNodes() *SchedulersWithMostAndLeastNumberOfNodes

GetSchedulersWithMostAndLeastNumberOfNodes returns the schedulers info with most and least number of nodes

func (*SchedulerMaintainer) GetSomeNodeNamesFromGeneralActiveScheduler 

func (maintainer *SchedulerMaintainer) GetSomeNodeNamesFromGeneralActiveScheduler(numberOfNodes int, schedulerName string) ([]string, error)

func (*SchedulerMaintainer) IsSchedulerInActiveQueue 

func (maintainer *SchedulerMaintainer) IsSchedulerInActiveQueue(schedulerName string) bool

IsSchedulerInActiveQueue checks whether the schedulers is active

func (*SchedulerMaintainer) IsSchedulerInInactiveQueue 

func (maintainer *SchedulerMaintainer) IsSchedulerInInactiveQueue(schedulerName string) bool

IsSchedulerInInactiveQueue checks whether the schedulers is inactive

func (*SchedulerMaintainer) PopulateSchedulers 

func (maintainer *SchedulerMaintainer) PopulateSchedulers()

PopulateSchedulers will populate existing schedulers to active queue

func (*SchedulerMaintainer) Run 

func (maintainer *SchedulerMaintainer) Run(stopCh <-chan struct{})

Run runs all necessary workers

func (*SchedulerMaintainer) SchedulerExist 

func (maintainer *SchedulerMaintainer) SchedulerExist(schedulerName string) bool

func (*SchedulerMaintainer) SyncUpSchedulersStatus 

func (maintainer *SchedulerMaintainer) SyncUpSchedulersStatus()

SyncUpSchedulersStatus will be responsible for syncing up schedulers between active queue and inactive queue TODO: we need to handle this scenario: schedulers exists in both active queue and inactive queue be careful about the race condition when we handle the scenario above we can delete schedulers from one of the queues based on schedulers actual status

func (*SchedulerMaintainer) SyncupNodePartitionType 

func (maintainer *SchedulerMaintainer) SyncupNodePartitionType()

func (*SchedulerMaintainer) UpdateNMNodeInGodelSchedulerIfNecessary 

func (maintainer *SchedulerMaintainer) UpdateNMNodeInGodelSchedulerIfNecessary(oldNMNode *nodev1alpha1.NMNode, newNMNode *nodev1alpha1.NMNode) error

UpdateNMNodeInGodelSchedulerIfNecessary updates nmnode info for specific godel schedulers

func (*SchedulerMaintainer) UpdateNodeInGodelSchedulerIfNecessary 

func (maintainer *SchedulerMaintainer) UpdateNodeInGodelSchedulerIfNecessary(oldNode *v1.Node, newNode *v1.Node) error

UpdateNodeInGodelSchedulerIfNecessary updates node info for specific godel schedulers

func (*SchedulerMaintainer) UpdateScheduler 

func (maintainer *SchedulerMaintainer) UpdateScheduler(oldScheduler *schedulerapi.Scheduler, newScheduler *schedulerapi.Scheduler)

UpdateScheduler updates schedulers info in maintainer cache

type SchedulerNodePartitionType 

type SchedulerNodePartitionType string
const (
	// if schedulers crd is not updated for 2 minutes (MaxSchedulerCRDNotUpdateDuration), schedulers will be considered as inactive
	MaxSchedulerCRDNotUpdateDuration = 2 * time.Minute

	Physical SchedulerNodePartitionType = "Physical"
	Logical  SchedulerNodePartitionType = "Logical"
)

type SchedulersWithLeastNumberOfNodes 

type SchedulersWithLeastNumberOfNodes struct {
	LeastNumberOfNodesSchedulerName string
	LeastNumberOfNodes              int
}

SchedulersWithLeastNumberOfNodes stores the schedulers names with the least number of nodes, as well as the number of nodes

type SchedulersWithMostAndLeastNumberOfNodes 

type SchedulersWithMostAndLeastNumberOfNodes struct {
	MostNumberOfNodesSchedulerName  string
	MostNumberOfNodes               int
	LeastNumberOfNodesSchedulerName string
	LeastNumberOfNodes              int
}

SchedulersWithMostAndLeastNumberOfNodes stores the schedulers names with most and least number of nodes, as well as the number of nodes

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.