Documentation
¶
Index ¶
- func AllocateJob(ssn *framework.Session, stmt *framework.Statement, nodes []*node_info.NodeInfo, ...) bool
- func EvictAllPreemptees(ssn *framework.Session, preempteeTasks []*pod_info.PodInfo, ...) error
- func FeasibleNodesForJob(allNodes []*node_info.NodeInfo, job *podgroup_info.PodGroupInfo) []*node_info.NodeInfo
- func GetJobsToAllocate(ssn *framework.Session, preempteeTasks []*pod_info.PodInfo, ...) *utils.JobsOrderByQueues
- func TryToVirtuallyAllocatePreemptorAndGetVictims(ssn *framework.Session, stmt *framework.Statement, nodes []*node_info.NodeInfo, ...) (bool, []*pod_info.PodInfo)
- type MinimalJobRepresentatives
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AllocateJob ¶
func AllocateJob(ssn *framework.Session, stmt *framework.Statement, nodes []*node_info.NodeInfo, job *podgroup_info.PodGroupInfo, isPipelineOnly bool) bool
func EvictAllPreemptees ¶
func EvictAllPreemptees(ssn *framework.Session, preempteeTasks []*pod_info.PodInfo, preemptor *podgroup_info.PodGroupInfo, stmt *framework.Statement, actionType framework.ActionType) error
func FeasibleNodesForJob ¶
func FeasibleNodesForJob(allNodes []*node_info.NodeInfo, job *podgroup_info.PodGroupInfo) []*node_info.NodeInfo
func GetJobsToAllocate ¶
func GetJobsToAllocate(ssn *framework.Session, preempteeTasks []*pod_info.PodInfo, preemptor *podgroup_info.PodGroupInfo) *utils.JobsOrderByQueues
func TryToVirtuallyAllocatePreemptorAndGetVictims ¶
func TryToVirtuallyAllocatePreemptorAndGetVictims( ssn *framework.Session, stmt *framework.Statement, nodes []*node_info.NodeInfo, preemptor *podgroup_info.PodGroupInfo, jobsToAllocate *utils.JobsOrderByQueues, preempteeTasks []*pod_info.PodInfo, ) (bool, []*pod_info.PodInfo)
Types ¶
type MinimalJobRepresentatives ¶
type MinimalJobRepresentatives struct {
// contains filtered or unexported fields
}
func NewMinimalJobRepresentatives ¶
func NewMinimalJobRepresentatives() *MinimalJobRepresentatives
func (*MinimalJobRepresentatives) IsEasierToSchedule ¶
func (m *MinimalJobRepresentatives) IsEasierToSchedule(otherJob *podgroup_info.PodGroupInfo) (bool, *podgroup_info.PodGroupInfo)
func (*MinimalJobRepresentatives) UpdateRepresentative ¶
func (m *MinimalJobRepresentatives) UpdateRepresentative(newJob *podgroup_info.PodGroupInfo)
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.