internaltypes

Documentation

Index

• func QuantityToInt64RoundDown(q resource.Quantity, scale resource.Scale) int64
• func QuantityToInt64RoundUp(q resource.Quantity, scale resource.Scale) int64
• 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
• type ResourceList
  • func (rl *ResourceList) GetByName(name string) (int64, error)
• type ResourceListFactory
  • func MakeResourceListFactory(supportedResourceTypes []configuration.ResourceType) (*ResourceListFactory, error)
  • func (factory *ResourceListFactory) FromJobProto(resources schedulerobjects.ResourceList) (ResourceList, error)
  • func (factory *ResourceListFactory) FromNodeProto(resources schedulerobjects.ResourceList) ResourceList
  • func (factory *ResourceListFactory) SummaryString() string

Functions

func QuantityToInt64RoundDown

func QuantityToInt64RoundDown(q resource.Quantity, scale resource.Scale) int64

func QuantityToInt64RoundUp

func QuantityToInt64RoundUp(q resource.Quantity, scale resource.Scale) int64

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.

type ResourceList

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

func (*ResourceList) GetByName

func (rl *ResourceList) GetByName(name string) (int64, error)

type ResourceListFactory

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

func MakeResourceListFactory

func MakeResourceListFactory(supportedResourceTypes []configuration.ResourceType) (*ResourceListFactory, error)

func (*ResourceListFactory) FromJobProto

func (factory *ResourceListFactory) FromJobProto(resources schedulerobjects.ResourceList) (ResourceList, error)

Fail on unknown resources, round up.

func (*ResourceListFactory) FromNodeProto

func (factory *ResourceListFactory) FromNodeProto(resources schedulerobjects.ResourceList) ResourceList

Ignore unknown resources, round down.

func (*ResourceListFactory) SummaryString

func (factory *ResourceListFactory) SummaryString() string