api

type CanReclaimResourcesFn ¶

type CanReclaimResourcesFn func(*reclaimer_info.ReclaimerInfo) bool

CanReclaimResourcesFn is a function that determines if a reclaimer can get more resources

type ClusterInfo ¶

type ClusterInfo struct {
	Pods                        []*v1.Pod
	PodGroupInfos               map[common_info.PodGroupID]*podgroup_info.PodGroupInfo
	Nodes                       map[string]*node_info.NodeInfo
	BindRequests                bindrequest_info.BindRequestMap
	BindRequestsForDeletedNodes []*bindrequest_info.BindRequestInfo
	Queues                      map[common_info.QueueID]*queue_info.QueueInfo
	Departments                 map[common_info.QueueID]*queue_info.QueueInfo
	StorageClaims               map[storageclaim_info.Key]*storageclaim_info.StorageClaimInfo
	StorageCapacities           map[common_info.StorageCapacityID]*storagecapacity_info.StorageCapacityInfo
	CSIDrivers                  map[common_info.CSIDriverID]*csidriver_info.CSIDriverInfo
	StorageClasses              map[common_info.StorageClassID]*storageclass_info.StorageClassInfo
	ConfigMaps                  map[common_info.ConfigMapID]*configmap_info.ConfigMapInfo
}

ClusterInfo is a snapshot of cluster by cache.

func NewClusterInfo() *ClusterInfo

func (ci ClusterInfo) String() string

type EvictableFn ¶

type EvictableFn func(*reclaimer_info.ReclaimerInfo, map[common_info.QueueID][]*resource_info.Resource) bool

EvictableFn is a function which determines if a reclaimer can reclaim a victim.

type GpuOrderFn ¶

type GpuOrderFn func(*pod_info.PodInfo, *node_info.NodeInfo, string) (float64, error)

GpuOrderFn is used to get priority score for a gpu for a particular task.

type IsJobOverCapacityFn ¶

type IsJobOverCapacityFn func(job *podgroup_info.PodGroupInfo, tasksToAllocate []*pod_info.PodInfo) *SchedulableResult

IsJobOverCapacityFn is a function which determines if a job is over queue capacity.

type IsTaskAllocationOverCapacityFn ¶

type IsTaskAllocationOverCapacityFn func(task *pod_info.PodInfo, job *podgroup_info.PodGroupInfo, node *node_info.NodeInfo) *SchedulableResult

IsTaskAllocationOverCapacityFn is a function which determines if a task is over capacity.

type NodeOrderFn ¶

type NodeOrderFn func(*pod_info.PodInfo, *node_info.NodeInfo) (float64, error)

NodeOrderFn is used to get priority score for a node for a particular task.

type NodePreOrderFn ¶

type NodePreOrderFn func(*pod_info.PodInfo, []*node_info.NodeInfo) error

NodePreOrderFn is used for pre-calculations on the feasible nodes for pods. Outputs of these calculations will be used in the NodeOrderFn

type OnJobSolutionStartFn ¶

type OnJobSolutionStartFn func()

OnJobSolutionStartFn is used for notifying on job solution (and scenario simulations) start

type PrePredicateFn ¶

type PrePredicateFn func(*pod_info.PodInfo, *podgroup_info.PodGroupInfo) error

PrePredicateFn is used to prepare for predicate on pod.

type PredicateFn ¶

type PredicateFn func(*pod_info.PodInfo, *podgroup_info.PodGroupInfo, *node_info.NodeInfo) error

PredicateFn is used to predicate node for task.

type QueueResource ¶

type QueueResource func(*queue_info.QueueInfo) *resource_info.ResourceRequirements

QueueResource is a function which returns the resource of a queue.

type SchedulableResult ¶

type SchedulableResult struct {
	IsSchedulable bool
	Reason        v2alpha2.UnschedulableReason
	Message       string
	Details       *v2alpha2.UnschedulableExplanationDetails
}