util

Documentation

Index

• Constants
• func CalculateAllocatedTaskNum(job *api.JobInfo) int
• func GetAllocatedResource(job *api.JobInfo) *api.Resource
• func GetInqueueResource(job *api.JobInfo, allocated *api.Resource) *api.Resource
• func NormalizeScore(maxPriority int64, reverse bool, scores []api.ScoredNode)

Constants

const (
	// Permit indicates that plugin callback function permits job to be inqueue, pipelined, or other status
	Permit = 1
	// Abstain indicates that plugin callback function abstains in voting job to be inqueue, pipelined, or other status
	Abstain = 0
	// Reject indicates that plugin callback function rejects job to be inqueue, pipelined, or other status
	Reject = -1
)

Functions

func CalculateAllocatedTaskNum

func CalculateAllocatedTaskNum(job *api.JobInfo) int

CalculateAllocatedTaskNum returns allocated resource num for given job

func GetAllocatedResource

func GetAllocatedResource(job *api.JobInfo) *api.Resource

GetAllocatedResource returns allocated resource for given job

func GetInqueueResource

func GetInqueueResource(job *api.JobInfo, allocated *api.Resource) *api.Resource

GetInqueueResource returns reserved resource for running job whose part of pods have not been allocated resource.

func NormalizeScore

func NormalizeScore(maxPriority int64, reverse bool, scores []api.ScoredNode)

NormalizeScore normalizes the score for each filteredNode