selector

Documentation

Index

• type NodeSelector
  • func NewNodeSelector(discoverer nodes.Lookup, ranker orchestrator.NodeRanker, ...) *NodeSelector
  • func (n NodeSelector) AllNodes(ctx context.Context) ([]models.NodeInfo, error)
  • func (n NodeSelector) MatchingNodes(ctx context.Context, job *models.Job) (matchingNodes, rejectedNodes []orchestrator.NodeRank, err error)

Types

type NodeSelector

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

func NewNodeSelector

func NewNodeSelector(
	discoverer nodes.Lookup,
	ranker orchestrator.NodeRanker,
	constraints orchestrator.NodeSelectionConstraints,
) *NodeSelector

func (NodeSelector) AllNodes

func (n NodeSelector) AllNodes(ctx context.Context) ([]models.NodeInfo, error)

func (NodeSelector) MatchingNodes

func (n NodeSelector) MatchingNodes(
	ctx context.Context,
	job *models.Job,
) (matchingNodes, rejectedNodes []orchestrator.NodeRank, err error)