capacity

Documentation

Index

• func GetNodeCapacity(available, reserved, singleExecutor *resources.Resources) int
• type NodeAndExecutorCapacity
  • func FilterOutNodesWithoutCapacity(capacities []NodeAndExecutorCapacity) []NodeAndExecutorCapacity
  • func GetNodeCapacities(nodePriorityOrder []string, ...) []NodeAndExecutorCapacity

Functions

func GetNodeCapacity

func GetNodeCapacity(available, reserved, singleExecutor *resources.Resources) int

GetNodeCapacity returns how many singleExecutor can fit within available - reserved

Types

type NodeAndExecutorCapacity

type NodeAndExecutorCapacity struct {
	NodeName string
	Capacity int
}

NodeAndExecutorCapacity is a pair of node name and capacity (how many executors can it fit)

func FilterOutNodesWithoutCapacity

func FilterOutNodesWithoutCapacity(capacities []NodeAndExecutorCapacity) []NodeAndExecutorCapacity

FilterOutNodesWithoutCapacity returns a slice of nodes with non-zero capacity

func GetNodeCapacities

func GetNodeCapacities(
	nodePriorityOrder []string,
	nodeGroupSchedulingMetadata resources.NodeGroupSchedulingMetadata,
	reservedResources resources.NodeGroupResources,
	singleExecutor *resources.Resources,
) []NodeAndExecutorCapacity

GetNodeCapacities return value is ordered according to nodePriorityOrder