sort

Documentation

Index

• type NodeSorter
  • func NewNodeSorter(driverPrioritizedNodeLabel *config.LabelPriorityOrder, ...) *NodeSorter
  • func (n *NodeSorter) PotentialNodes(availableNodesSchedulingMetadata resources.NodeGroupSchedulingMetadata, ...) (driverNodes, executorNodes []string)

Types

type NodeSorter

type NodeSorter struct {
	// contains filtered or unexported fields
}

NodeSorter sorts nodes based on configured node labels and allocated resources.

func NewNodeSorter

func NewNodeSorter(
	driverPrioritizedNodeLabel *config.LabelPriorityOrder,
	executorPrioritizedNodeLabel *config.LabelPriorityOrder) *NodeSorter

NewNodeSorter creates a new NodeSorter instance.

func (*NodeSorter) PotentialNodes

func (n *NodeSorter) PotentialNodes(availableNodesSchedulingMetadata resources.NodeGroupSchedulingMetadata, nodeNames []string) (driverNodes, executorNodes []string)

PotentialNodes returns driver and executor nodes in priority order based on scheduling metadata and a list of candidate nodes for the driver.