podgroup_info

package
v0.12.14 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 18, 2026 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	OverCapacity        = "OverCapacity"
	PodSchedulingErrors = "PodSchedulingErrors"
	DefaultSubGroup     = "default"
)

Variables

This section is empty.

Functions

func GetTasksToAllocate 

func GetTasksToAllocate(
	podGroupInfo *PodGroupInfo, subGroupOrderFn common_info.LessFn, taskOrderFn common_info.LessFn,
	isRealAllocation bool,
) []*pod_info.PodInfo

func GetTasksToAllocateInitResource 

func GetTasksToAllocateInitResource(
	podGroupInfo *PodGroupInfo, subGroupOrderFn common_info.LessFn, taskOrderFn common_info.LessFn,
	isRealAllocation bool, minNodeGPUMemory int64,
) *resource_info.Resource

func GetTasksToAllocateRequestedGPUs 

func GetTasksToAllocateRequestedGPUs(
	podGroupInfo *PodGroupInfo, subGroupOrderFn common_info.LessFn, taskOrderFn common_info.LessFn,
	isRealAllocation bool,
) (float64, int64)

func GetTasksToEvict 

func GetTasksToEvict(job *PodGroupInfo, subGroupOrderFn, taskOrderFn common_info.LessFn) ([]*pod_info.PodInfo, bool)

func HasTasksToAllocate 

func HasTasksToAllocate(podGroupInfo *PodGroupInfo, isRealAllocation bool) bool

Types

type JobRequirement 

type JobRequirement struct {
	GPU      float64
	MilliCPU float64
	Memory   float64
}

func (*JobRequirement) Get 

func (jr *JobRequirement) Get(resourceName v1.ResourceName) float64

type PodGroupInfo 

type PodGroupInfo struct {
	UID common_info.PodGroupID

	Name           string
	Namespace      string
	NamespacedName string

	Queue common_info.QueueID

	Priority       int32
	Preemptibility enginev2alpha2.Preemptibility

	JobFitErrors   []common_info.JobFitError
	TasksFitErrors map[common_info.PodID]*common_info.TasksFitErrors

	Allocated *resource_info.Resource

	CreationTimestamp  metav1.Time
	LastStartTimestamp *time.Time
	PodGroup           *enginev2alpha2.PodGroup
	PodGroupUID        types.UID

	RootSubGroupSet *subgroup_info.SubGroupSet
	PodSets         map[string]*subgroup_info.PodSet

	StalenessInfo

	PodStatusIndex map[pod_status.PodStatus]pod_info.PodsMap
	// contains filtered or unexported fields
}

func NewPodGroupInfo 

func NewPodGroupInfo(uid common_info.PodGroupID, tasks ...*pod_info.PodInfo) *PodGroupInfo

func (*PodGroupInfo) AddJobFitError added in v0.12.0 

func (pgi *PodGroupInfo) AddJobFitError(err common_info.JobFitError)

func (*PodGroupInfo) AddSimpleJobFitError added in v0.12.0 

func (pgi *PodGroupInfo) AddSimpleJobFitError(reason enginev2alpha2.UnschedulableReason, message string)

func (*PodGroupInfo) AddTaskFitErrors added in v0.12.0 

func (pgi *PodGroupInfo) AddTaskFitErrors(task *pod_info.PodInfo, fitErrors *common_info.TasksFitErrors)

func (*PodGroupInfo) AddTaskInfo 

func (pgi *PodGroupInfo) AddTaskInfo(ti *pod_info.PodInfo)

func (*PodGroupInfo) Clone 

func (pgi *PodGroupInfo) Clone() *PodGroupInfo

func (*PodGroupInfo) CloneWithTasks 

func (pgi *PodGroupInfo) CloneWithTasks(tasks []*pod_info.PodInfo) *PodGroupInfo

func (*PodGroupInfo) GetActiveAllocatedTasksCount added in v0.4.8 

func (pgi *PodGroupInfo) GetActiveAllocatedTasksCount() int

func (*PodGroupInfo) GetActivelyRunningTasksCount added in v0.4.8 

func (pgi *PodGroupInfo) GetActivelyRunningTasksCount() int32

func (*PodGroupInfo) GetAliveTasksRequestedGPUs 

func (pgi *PodGroupInfo) GetAliveTasksRequestedGPUs() float64

func (*PodGroupInfo) GetAllPodsMap added in v0.8.1 

func (pgi *PodGroupInfo) GetAllPodsMap() pod_info.PodsMap

func (*PodGroupInfo) GetNumActiveUsedTasks 

func (pgi *PodGroupInfo) GetNumActiveUsedTasks() int

func (*PodGroupInfo) GetNumAliveTasks 

func (pgi *PodGroupInfo) GetNumAliveTasks() int

func (*PodGroupInfo) GetNumAllocatedTasks added in v0.5.2 

func (pgi *PodGroupInfo) GetNumAllocatedTasks() int

func (*PodGroupInfo) GetNumGatedTasks added in v0.5.1 

func (pgi *PodGroupInfo) GetNumGatedTasks() int

func (*PodGroupInfo) GetNumPendingTasks 

func (pgi *PodGroupInfo) GetNumPendingTasks() int

func (*PodGroupInfo) GetPendingTasks 

func (pgi *PodGroupInfo) GetPendingTasks() []*pod_info.PodInfo

func (*PodGroupInfo) GetSchedulingConstraintsSignature 

func (pgi *PodGroupInfo) GetSchedulingConstraintsSignature() common_info.SchedulingConstraintsSignature

func (*PodGroupInfo) GetSubGroups added in v0.8.3 

func (pgi *PodGroupInfo) GetSubGroups() map[string]*subgroup_info.PodSet

func (*PodGroupInfo) GetTasksActiveAllocatedReqResource 

func (pgi *PodGroupInfo) GetTasksActiveAllocatedReqResource() *resource_info.Resource

func (*PodGroupInfo) IsElastic added in v0.6.0 

func (pgi *PodGroupInfo) IsElastic() bool

func (*PodGroupInfo) IsGangSatisfied added in v0.7.10 

func (pgi *PodGroupInfo) IsGangSatisfied() bool

func (*PodGroupInfo) IsPreemptibleJob 

func (pgi *PodGroupInfo) IsPreemptibleJob() bool

func (*PodGroupInfo) IsReadyForScheduling 

func (pgi *PodGroupInfo) IsReadyForScheduling() bool

func (*PodGroupInfo) IsStale added in v0.7.10 

func (pgi *PodGroupInfo) IsStale() bool

func (*PodGroupInfo) SetPodGroup 

func (pgi *PodGroupInfo) SetPodGroup(pg *enginev2alpha2.PodGroup)

func (*PodGroupInfo) ShouldPipelineJob 

func (pgi *PodGroupInfo) ShouldPipelineJob() bool

func (*PodGroupInfo) String 

func (pgi *PodGroupInfo) String() string

func (*PodGroupInfo) UpdateTaskStatus 

func (pgi *PodGroupInfo) UpdateTaskStatus(task *pod_info.PodInfo, status pod_status.PodStatus) error

type PodGroupInfos added in v0.4.8 

type PodGroupInfos struct {
	PodGroupInfos []*PodGroupInfo
}

type StalenessInfo 

type StalenessInfo struct {
	TimeStamp *time.Time
	Stale     bool
}

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.