node_manager

Documentation

Index

• type NodeManager
  • func NewNodeManager(nodepools []*pb.NodePool) (*NodeManager, error)
  • func (nm *NodeManager) Arch(np *pb.NodePool) (nodes.Arch, error)
  • func (nm *NodeManager) GetCapacity(np *pb.NodePool) k8sV1.ResourceList
  • func (nm *NodeManager) Refresh(nodepools []*pb.NodePool) error

Types

type NodeManager

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

func NewNodeManager

func NewNodeManager(nodepools []*pb.NodePool) (*NodeManager, error)

NewNodeManager returns a NodeManager pointer with initialised caches about nodes.

func (*NodeManager) Arch

func (nm *NodeManager) Arch(np *pb.NodePool) (nodes.Arch, error)

Arch returns the architecture for the dynamic nodepool.

func (*NodeManager) GetCapacity

func (nm *NodeManager) GetCapacity(np *pb.NodePool) k8sV1.ResourceList

GetCapacity returns a theoretical capacity for a new node from specified nodepool.

func (*NodeManager) Refresh

func (nm *NodeManager) Refresh(nodepools []*pb.NodePool) error

Refresh checks if the information about specified nodepools needs refreshing, and if so, refreshes it.