capacity_policy

Documentation

Index

• func Schedulable() *api.SchedulableResult
• type CapacityPolicy
  • func New(queues map[common_info.QueueID]*rs.QueueAttributes) *CapacityPolicy
  • func (cp *CapacityPolicy) IsJobOverQueueCapacity(job *podgroup_info.PodGroupInfo, tasksToAllocate []*pod_info.PodInfo) *api.SchedulableResult
  • func (cp *CapacityPolicy) IsNonPreemptibleJobOverQuota(job *podgroup_info.PodGroupInfo, tasksToAllocate []*pod_info.PodInfo) *api.SchedulableResult
  • func (cp *CapacityPolicy) IsTaskAllocationOnNodeOverCapacity(task *pod_info.PodInfo, job *podgroup_info.PodGroupInfo, ...) *api.SchedulableResult

Functions

func Schedulable

func Schedulable() *api.SchedulableResult

Types

type CapacityPolicy

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

func New

func New(queues map[common_info.QueueID]*rs.QueueAttributes) *CapacityPolicy

func (*CapacityPolicy) IsJobOverQueueCapacity

func (cp *CapacityPolicy) IsJobOverQueueCapacity(job *podgroup_info.PodGroupInfo,
	tasksToAllocate []*pod_info.PodInfo) *api.SchedulableResult

func (*CapacityPolicy) IsNonPreemptibleJobOverQuota

func (cp *CapacityPolicy) IsNonPreemptibleJobOverQuota(job *podgroup_info.PodGroupInfo,
	tasksToAllocate []*pod_info.PodInfo) *api.SchedulableResult

func (*CapacityPolicy) IsTaskAllocationOnNodeOverCapacity

func (cp *CapacityPolicy) IsTaskAllocationOnNodeOverCapacity(task *pod_info.PodInfo, job *podgroup_info.PodGroupInfo,
	node *node_info.NodeInfo) *api.SchedulableResult