internaltypes

Documentation

Index

• type Node
  • func CreateNode(id string, nodeTypeId uint64, index uint64, executor string, name string, ...) *Node
  • func (node *Node) FindMatchingUntoleratedTaint(tolerations ...[]v1.Toleration) (v1.Taint, bool)
  • func (node *Node) GetExecutor() string
  • func (node *Node) GetId() string
  • func (node *Node) GetIndex() uint64
  • func (node *Node) GetLabelValue(key string) (string, bool)
  • func (node *Node) GetLabels() map[string]string
  • func (node *Node) GetName() string
  • func (node *Node) GetNodeTypeId() uint64
  • func (node *Node) GetTaints() []v1.Taint
  • func (node *Node) GetTolerationsForTaints() []v1.Toleration
  • func (node *Node) MatchNodeSelectorTerms(nodeSelector *v1.NodeSelector) (bool, error)
  • func (node *Node) UnsafeCopy() *Node

Types

type Node

type Node struct {
	TotalResources schedulerobjects.ResourceList

	// This field is set when inserting the Node into a NodeDb.
	Keys [][]byte

	AllocatableByPriority schedulerobjects.AllocatableByPriorityAndResourceType
	AllocatedByQueue      map[string]schedulerobjects.ResourceList
	AllocatedByJobId      map[string]schedulerobjects.ResourceList
	EvictedJobRunIds      map[string]bool
	// contains filtered or unexported fields
}

func CreateNode

func CreateNode(
	id string,
	nodeTypeId uint64,
	index uint64,
	executor string,
	name string,
	taints []v1.Taint,
	labels map[string]string,
	totalResources schedulerobjects.ResourceList,
	allocatableByPriority schedulerobjects.AllocatableByPriorityAndResourceType,
	allocatedByQueue map[string]schedulerobjects.ResourceList,
	allocatedByJobId map[string]schedulerobjects.ResourceList,
	evictedJobRunIds map[string]bool,
	keys [][]byte,
) *Node

func (*Node) FindMatchingUntoleratedTaint

func (node *Node) FindMatchingUntoleratedTaint(tolerations ...[]v1.Toleration) (v1.Taint, bool)

func (*Node) GetExecutor

func (node *Node) GetExecutor() string

func (*Node) GetId

func (node *Node) GetId() string

func (*Node) GetIndex

func (node *Node) GetIndex() uint64

func (*Node) GetLabelValue

func (node *Node) GetLabelValue(key string) (string, bool)

func (*Node) GetLabels

func (node *Node) GetLabels() map[string]string

func (*Node) GetName

func (node *Node) GetName() string

func (*Node) GetNodeTypeId

func (node *Node) GetNodeTypeId() uint64

func (*Node) GetTaints

func (node *Node) GetTaints() []v1.Taint

func (*Node) GetTolerationsForTaints

func (node *Node) GetTolerationsForTaints() []v1.Toleration

func (*Node) MatchNodeSelectorTerms

func (node *Node) MatchNodeSelectorTerms(nodeSelector *v1.NodeSelector) (bool, error)

func (*Node) UnsafeCopy

func (node *Node) UnsafeCopy() *Node

UnsafeCopy returns a pointer to a new value of type Node; it is unsafe because it only makes shallow copies of fields that are not mutated by methods of NodeDb.