nodes

Documentation

Index

• type NodeClaimWrapper
  • func NewNodeClaimWrapper(claim *pb.NodeClaim) (*NodeClaimWrapper, error)
  • func (w *NodeClaimWrapper) IsNodeAffinityMatched(node *corev1.Node) bool
  • func (w *NodeClaimWrapper) IsNodeMatched(node *corev1.Node) bool
  • func (w *NodeClaimWrapper) IsNodeSchedulable(node *corev1.Node) bool
  • func (w *NodeClaimWrapper) ListNodesByLabelSelector(nodeLister listv1.NodeLister) ([]*corev1.Node, error)
• type NodeInfo
  • func NewNodeInfo(node *corev1.Node) *NodeInfo
  • func (ni *NodeInfo) AssignedPodRequest(pods []*corev1.Pod) error
  • func (ni *NodeInfo) MaxReplicaDivided(rl corev1.ResourceList) int64

Types

type NodeClaimWrapper

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

NodeClaimWrapper is a wrapper that wraps the node claim.

func NewNodeClaimWrapper

func NewNodeClaimWrapper(claim *pb.NodeClaim) (*NodeClaimWrapper, error)

NewNodeClaimWrapper returns a new NodeClaimWrapper.

func (*NodeClaimWrapper) IsNodeAffinityMatched

func (w *NodeClaimWrapper) IsNodeAffinityMatched(node *corev1.Node) bool

IsNodeAffinityMatched returns whether the node matches the node affinity.

func (*NodeClaimWrapper) IsNodeMatched

func (w *NodeClaimWrapper) IsNodeMatched(node *corev1.Node) bool

IsNodeMatched returns whether the node matches all conditions.

func (*NodeClaimWrapper) IsNodeSchedulable

func (w *NodeClaimWrapper) IsNodeSchedulable(node *corev1.Node) bool

IsNodeSchedulable returns whether the node matches the tolerations.

func (*NodeClaimWrapper) ListNodesByLabelSelector

func (w *NodeClaimWrapper) ListNodesByLabelSelector(nodeLister listv1.NodeLister) ([]*corev1.Node, error)

ListNodesByLabelSelector returns nodes that match the node selector.

type NodeInfo

type NodeInfo struct {
	Node *corev1.Node

	AllocatableResource *util.Resource
	IdleResource        *util.Resource
}

NodeInfo is the wrapper of a node and its resource.

func NewNodeInfo

func NewNodeInfo(node *corev1.Node) *NodeInfo

NewNodeInfo returns an instance of NodeInfo. The initial IdleResource equals with AllocatableResource.

func (*NodeInfo) AssignedPodRequest

func (ni *NodeInfo) AssignedPodRequest(pods []*corev1.Pod) error

AssignedPodRequest counts the effective request resource of pods for the node. IdleResource will be subtracted from the all pod request resources when this function is called.

func (*NodeInfo) MaxReplicaDivided

func (ni *NodeInfo) MaxReplicaDivided(rl corev1.ResourceList) int64

MaxReplicaDivided returns how many replicas that the node can produce.