nodedb

Oct 11, 2024

Changes in this version

type NodeDb

+ func (nodeDb *NodeDb) TotalKubernetesResources() schedulerobjects.ResourceList

Sep 30, 2024

Changes in this version

type NodeDb

+ func (nodeDb *NodeDb) AddNodeToDb(node *internaltypes.Node)

Apr 15, 2024

Changes in this version

type PodRequirementsNotMetReason

+ func NodeTolerationRequirementsMet(node *internaltypes.Node, tolerations ...[]v1.Toleration) (bool, PodRequirementsNotMetReason)

Mar 1, 2024

Changes in this version

type Node

+ Index uint64

Dec 19, 2023

Changes in this version

type NodeDb

+ func (nodeDb *NodeDb) EvictJobsFromNode(priorityClasses map[string]types.PriorityClass, ...) ([]interfaces.LegacySchedulerJob, *Node, error)

+ func (nodeDb *NodeDb) GetScheduledAtPriority(jobId string) (int32, bool)

+ func (nodeDb *NodeDb) UnbindJobFromNode(priorityClasses map[string]types.PriorityClass, ...) (*Node, error)

+ func (nodeDb *NodeDb) UnbindJobsFromNode(priorityClasses map[string]types.PriorityClass, ...) (*Node, error)

Nov 21, 2023

Changes in this version

+ const PodRequirementsNotMetReasonInsufficientResources

+ const PodRequirementsNotMetReasonUnknown

+ const PodRequirementsNotMetReasonUnmatchedNodeSelector

+ const SchedulableBestScore

+ const SchedulableScore

+ type InsufficientResources struct

+ Available resource.Quantity

+ Required resource.Quantity

+ ResourceName string

+ func (err *InsufficientResources) String() string

+ func (r *InsufficientResources) Sum64() uint64

+ type MissingLabel struct

+ Label string

+ func (r *MissingLabel) String() string

+ func (r *MissingLabel) Sum64() uint64

type NodeDb

+ func (nodeDb *NodeDb) NodeTypesMatchingJob(jctx *schedulercontext.JobSchedulingContext) ([]*schedulerobjects.NodeType, map[string]int, error)

+ type PodRequirementsNotMetReason interface

+ Sum64 func() uint64

+ func DynamicJobRequirementsMet(allocatableResources schedulerobjects.ResourceList, ...) (bool, int, PodRequirementsNotMetReason)

+ func JobRequirementsMet(taints []v1.Taint, labels map[string]string, ...) (bool, int, PodRequirementsNotMetReason, error)

+ func NodeAffinityRequirementsMet(nodeLabels map[string]string, nodeSelector *v1.NodeSelector) (bool, PodRequirementsNotMetReason, error)

+ func NodeSelectorRequirementsMet(nodeLabels, unsetIndexedLabels, nodeSelector map[string]string) (bool, PodRequirementsNotMetReason)

+ func NodeTypeJobRequirementsMet(nodeType *schedulerobjects.NodeType, ...) (bool, PodRequirementsNotMetReason)

+ func ResourceRequirementsMet(available schedulerobjects.ResourceList, required v1.ResourceList) (bool, PodRequirementsNotMetReason)

+ func StaticJobRequirementsMet(taints []v1.Taint, labels map[string]string, ...) (bool, PodRequirementsNotMetReason, error)

+ func TolerationRequirementsMet(taints []v1.Taint, tolerations ...[]v1.Toleration) (bool, PodRequirementsNotMetReason)

+ type UnmatchedLabel struct

+ Label string

+ NodeValue string

+ PodValue string

+ func (r *UnmatchedLabel) String() string

+ func (r *UnmatchedLabel) Sum64() uint64

+ type UnmatchedNodeSelector struct

+ NodeSelector *v1.NodeSelector

+ func (err *UnmatchedNodeSelector) String() string

+ func (r *UnmatchedNodeSelector) Sum64() uint64

+ type UntoleratedTaint struct

+ Taint v1.Taint

+ func (r *UntoleratedTaint) String() string

+ func (r *UntoleratedTaint) Sum64() uint64

Aug 17, 2023

Changes in this version

+ type EvictedJobSchedulingContext struct

+ Index int

+ JobId string

+ JobSchedulingContext *schedulercontext.JobSchedulingContext

type NodeDb

+ func (nodeDb *NodeDb) AddEvictedJobSchedulingContextWithTxn(txn *memdb.Txn, index int, jctx *schedulercontext.JobSchedulingContext) error

+ func (nodeDb *NodeDb) EnableNewPreemptionStrategy()

+ func (nodeDb *NodeDb) Reset() error

Jul 12, 2023

Changes in this version

type Node

+ Executor string

Jul 7, 2023

Changes in this version

+ const MinPriority

+ type Node struct

+ AllocatableByPriority schedulerobjects.AllocatableByPriorityAndResourceType

+ AllocatedByJobId map[string]schedulerobjects.ResourceList

+ AllocatedByQueue map[string]schedulerobjects.ResourceList

+ EvictedJobRunIds map[string]bool

+ Id string

+ Keys [][]byte

+ Labels map[string]string

+ Name string

+ NodeTypeId uint64

+ Taints []v1.Taint

+ TotalResources schedulerobjects.ResourceList

+ func EvictJobsFromNode(priorityClasses map[string]configuration.PriorityClass, ...) ([]interfaces.LegacySchedulerJob, *Node, error)

+ func (node *Node) UnsafeCopy() *Node

type NodeDb

+ func (nodeDb *NodeDb) CreateAndInsertWithApiJobsWithTxn(txn *memdb.Txn, jobs []*api.Job, node *schedulerobjects.Node) error

+ func (nodeDb *NodeDb) CreateAndInsertWithJobDbJobsWithTxn(txn *memdb.Txn, jobs []*jobdb.Job, node *schedulerobjects.Node) error

+ func (nodeDb *NodeDb) IndexedNodeLabelValues(label string) (map[string]struct{}, bool)

Jun 28, 2023

Changes in this version

+ func BindJobToNode(priorityClasses map[string]configuration.PriorityClass, ...) (*schedulerobjects.Node, error)

+ func EvictJobFromNode(priorityClasses map[string]configuration.PriorityClass, ...) (*schedulerobjects.Node, error)

+ func UnbindJobFromNode(priorityClasses map[string]configuration.PriorityClass, ...) (*schedulerobjects.Node, error)

+ func UnbindJobsFromNode(priorityClasses map[string]configuration.PriorityClass, ...) (*schedulerobjects.Node, error)

type NodeDb

+ func (nodeDb *NodeDb) SelectNodeForJobWithTxn(txn *memdb.Txn, jctx *schedulercontext.JobSchedulingContext) error

Jun 13, 2023

Changes in this version

+ func EncodeInt64(out []byte, val int64) []byte

+ func EncodeQuantity(out []byte, val resource.Quantity) []byte

+ func EncodeUint64(out []byte, val uint64) []byte

+ func NodeIndexKey(out []byte, nodeTypeId uint64, resources []resource.Quantity) []byte

+ func RoundedNodeIndexKeyFromResourceList(out []byte, nodeTypeId uint64, resourceNames []string, ...) []byte

+ type NodeIndex struct

+ KeyIndex int

+ func (index *NodeIndex) FromArgs(args ...interface{}) ([]byte, error)

+ func (index *NodeIndex) FromObject(raw interface{}) (bool, []byte, error)

May 12, 2023

Changes in this version

+ func UnschedulableTaint() v1.Taint

+ func UnschedulableToleration() v1.Toleration

May 8, 2023

Changes in this version

+ func BindPodToNode(req *schedulerobjects.PodRequirements, node *schedulerobjects.Node) (*schedulerobjects.Node, error)

+ func EvictPodFromNode(req *schedulerobjects.PodRequirements, node *schedulerobjects.Node) (*schedulerobjects.Node, error)

+ func JobIdFromPodRequirements(req *schedulerobjects.PodRequirements) (string, error)

+ func NodeJobDiff(txnA, txnB *memdb.Txn) (map[string]*schedulerobjects.Node, map[string]*schedulerobjects.Node, error)

+ func QueueFromPodRequirements(req *schedulerobjects.PodRequirements) (string, error)

+ func UnbindPodFromNode(req *schedulerobjects.PodRequirements, node *schedulerobjects.Node) (*schedulerobjects.Node, error)

+ func UnbindPodsFromNode(reqs []*schedulerobjects.PodRequirements, node *schedulerobjects.Node) (*schedulerobjects.Node, error)

+ type NodeAvailableResourceIndex struct

+ Priority int32

+ Resource string

+ func (index *NodeAvailableResourceIndex) FromArgs(args ...interface{}) ([]byte, error)

+ func (index *NodeAvailableResourceIndex) FromObject(raw interface{}) (bool, []byte, error)

+ type NodeDb struct

+ func NewNodeDb(priorityClasses map[string]configuration.PriorityClass, ...) (*NodeDb, error)

+ func (nodeDb *NodeDb) ClearAllocated() error

+ func (nodeDb *NodeDb) GetNode(id string) (*schedulerobjects.Node, error)

+ func (nodeDb *NodeDb) GetNodeWithTxn(txn *memdb.Txn, id string) (*schedulerobjects.Node, error)

+ func (nodeDb *NodeDb) NodeTypesMatchingPod(req *schedulerobjects.PodRequirements) ([]*schedulerobjects.NodeType, map[string]int, error)

+ func (nodeDb *NodeDb) NumNodes() int

+ func (nodeDb *NodeDb) ScheduleMany(reqs []*schedulerobjects.PodRequirements) ([]*schedulercontext.PodSchedulingContext, bool, error)

+ func (nodeDb *NodeDb) ScheduleManyWithTxn(txn *memdb.Txn, reqs []*schedulerobjects.PodRequirements) ([]*schedulercontext.PodSchedulingContext, bool, error)

+ func (nodeDb *NodeDb) SelectAndBindNodeToPod(req *schedulerobjects.PodRequirements) (*schedulercontext.PodSchedulingContext, error)

+ func (nodeDb *NodeDb) SelectAndBindNodeToPodWithTxn(txn *memdb.Txn, req *schedulerobjects.PodRequirements) (*schedulercontext.PodSchedulingContext, error)

+ func (nodeDb *NodeDb) SelectNodeForPod(req *schedulerobjects.PodRequirements) (*schedulercontext.PodSchedulingContext, error)

+ func (nodeDb *NodeDb) SelectNodeForPodWithTxn(txn *memdb.Txn, req *schedulerobjects.PodRequirements) (*schedulercontext.PodSchedulingContext, error)

+ func (nodeDb *NodeDb) String() string

+ func (nodeDb *NodeDb) TotalResources() schedulerobjects.ResourceList

+ func (nodeDb *NodeDb) Txn(write bool) *memdb.Txn

+ func (nodeDb *NodeDb) Upsert(node *schedulerobjects.Node) error

+ func (nodeDb *NodeDb) UpsertMany(nodes []*schedulerobjects.Node) error

+ func (nodeDb *NodeDb) UpsertManyWithTxn(txn *memdb.Txn, nodes []*schedulerobjects.Node) error

+ func (nodeDb *NodeDb) UpsertWithTxn(txn *memdb.Txn, node *schedulerobjects.Node) error

+ type NodeIterator interface

+ NextNode func() *schedulerobjects.Node

+ type NodePairIterator struct

+ func NewNodePairIterator(txnA, txnB *memdb.Txn) (*NodePairIterator, error)

+ func (it *NodePairIterator) Next() interface{}

+ func (it *NodePairIterator) NextItem() (rv *NodePairIteratorItem)

+ func (it *NodePairIterator) WatchCh() <-chan struct{}

+ type NodePairIteratorItem struct

+ NodeA *schedulerobjects.Node

+ NodeB *schedulerobjects.Node

+ type NodeTypeIterator struct

+ func NewNodeTypeIterator(txn *memdb.Txn, nodeTypeId string, priority int32, indexedResources []string, ...) (*NodeTypeIterator, error)

+ func (it *NodeTypeIterator) Next() interface{}

+ func (it *NodeTypeIterator) NextNode() (*schedulerobjects.Node, error)

+ func (it *NodeTypeIterator) WatchCh() <-chan struct{}

+ type NodeTypesIterator struct

+ func NewNodeTypesIterator(txn *memdb.Txn, nodeTypeIds []string, priority int32, ...) (*NodeTypesIterator, error)

+ func (it *NodeTypesIterator) Next() interface{}

+ func (it *NodeTypesIterator) NextNode() (*schedulerobjects.Node, error)

+ func (it *NodeTypesIterator) WatchCh() <-chan struct{}

+ type NodesIterator struct

+ func NewNodesIterator(txn *memdb.Txn) (*NodesIterator, error)

+ func (it *NodesIterator) Next() interface{}

+ func (it *NodesIterator) NextNode() *schedulerobjects.Node

+ func (it *NodesIterator) WatchCh() <-chan struct{}