jobs_fake

Documentation

Index

• func BuildJobInfo(name, namespace string, uid common_info.PodGroupID, ...) *podgroup_info.PodGroupInfo
• func BuildJobsAndTasksMaps(Jobs []*TestJobBasic) (map[common_info.PodGroupID]*podgroup_info.PodGroupInfo, ...)
• func CalcJobAndPodResources(job *TestJobBasic, jobAllocatedResource *resource_info.Resource, ...) (*v1.ResourceList, string, string, []string)
• func CalcRequiredMemory(job *TestJobBasic, requiredMemoryAsString string, requiredMemoryInput *string) *string
• func DefaultSubGroup(minAvailable int32) *subgroup_info.SubGroupSet
• type TestJobBasic

Functions

func BuildJobInfo

func BuildJobInfo(
	name, namespace string, uid common_info.PodGroupID, allocatedResource *resource_info.Resource,
	rootSubGroupSet *subgroup_info.SubGroupSet, taskInfos []*pod_info.PodInfo,
	priority int32, preemptibility enginev2alpha2.Preemptibility, queueUID common_info.QueueID,
	jobCreationTime time.Time, staleDuration *time.Duration,
) *podgroup_info.PodGroupInfo

func BuildJobsAndTasksMaps

func BuildJobsAndTasksMaps(Jobs []*TestJobBasic) (
	map[common_info.PodGroupID]*podgroup_info.PodGroupInfo, map[string]pod_info.PodsMap, map[string]map[string]bool)

func CalcJobAndPodResources

func CalcJobAndPodResources(job *TestJobBasic, jobAllocatedResource *resource_info.Resource,
	task *tasks_fake.TestTaskBasic, gpuGroups []string,
	usedSharedGPUs map[string]map[string]bool) (*v1.ResourceList, string, string, []string)

func CalcRequiredMemory

func CalcRequiredMemory(job *TestJobBasic, requiredMemoryAsString string, requiredMemoryInput *string) *string

func DefaultSubGroup

func DefaultSubGroup(minAvailable int32) *subgroup_info.SubGroupSet

Types

type TestJobBasic

type TestJobBasic struct {
	RequiredGPUsPerTask                 float64
	RequiredGpuMemory                   uint64
	RequiredCPUsPerTask                 float64
	RequiredMemoryPerTask               float64
	RequiredMultiFractionDevicesPerTask *uint64
	Priority                            int32
	Preemptibility                      enginev2alpha2.Preemptibility
	Name                                string
	Namespace                           string
	QueueName                           string
	IsBestEffortJob                     bool
	JobAgeInMinutes                     int
	DeleteJobInTest                     bool
	JobNotReadyForSsn                   bool
	Tasks                               []*tasks_fake.TestTaskBasic
	RootSubGroupSet                     *subgroup_info.SubGroupSet
	StaleDuration                       *time.Duration
}