testfixtures

package
v0.3.73 Latest Latest
Warning

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

 Go to latest Published: Jun 16, 2023 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	TestJobset                   = "testJobset"
	TestQueue                    = "testQueue"
	TestPool                     = "testPool"
	TestHostnameLabel            = "kubernetes.io/hostname"
	PriorityClass0               = "priority-0"
	PriorityClass1               = "priority-1"
	PriorityClass2               = "priority-2"
	PriorityClass2NonPreemptible = "priority-2-non-preemptible"
	PriorityClass3               = "priority-3"
)

Variables

View Source 
var (
	BaseTime, _         = time.Parse("2006-01-02T15:04:05.000Z", "2022-03-01T15:04:05.000Z")
	TestPriorityClasses = map[string]configuration.PriorityClass{
		PriorityClass0:               {Priority: 0, Preemptible: true},
		PriorityClass1:               {Priority: 1, Preemptible: true},
		PriorityClass2:               {Priority: 2, Preemptible: true},
		PriorityClass2NonPreemptible: {Priority: 2, Preemptible: false},
		PriorityClass3:               {Priority: 3, Preemptible: false},
	}
	TestDefaultPriorityClass         = PriorityClass3
	TestPriorities                   = []int32{0, 1, 2, 3}
	TestMaxExtraNodesToConsider uint = 1
	TestResources                    = []configuration.IndexedResource{
		{Name: "cpu", Resolution: resource.MustParse("1")},
		{Name: "memory", Resolution: resource.MustParse("128Mi")},
		{Name: "gpu", Resolution: resource.MustParse("1")},
	}
	TestResourceNames = util.Map(
		TestResources,
		func(v configuration.IndexedResource) string { return v.Name },
	)
	TestIndexedResourceResolutionMillis = util.Map(
		TestResources,
		func(v configuration.IndexedResource) int64 { return v.Resolution.MilliValue() },
	)
	TestIndexedTaints     = []string{"largeJobsOnly", "gpu"}
	TestIndexedNodeLabels = []string{"largeJobsOnly", "gpu"}
)

Functions

func ContextWithDefaultLogger 

func ContextWithDefaultLogger(ctx context.Context) context.Context

func IntRange 

func IntRange(a, b int) []int

func N16CpuJobs added in v0.3.69 

func N16CpuJobs(queue string, priorityClassName string, n int) []*jobdb.Job

func N16CpuPodReqs added in v0.3.69 

func N16CpuPodReqs(queue string, priority int32, n int) []*schedulerobjects.PodRequirements

func N1CpuJobs added in v0.3.69 

func N1CpuJobs(queue string, priorityClassName string, n int) []*jobdb.Job

func N1CpuPodReqs added in v0.3.69 

func N1CpuPodReqs(queue string, priority int32, n int) []*schedulerobjects.PodRequirements

func N1GpuJobs added in v0.3.69 

func N1GpuJobs(queue string, priorityClassName string, n int) []*jobdb.Job

func N1GpuPodReqs added in v0.3.69 

func N1GpuPodReqs(queue string, priority int32, n int) []*schedulerobjects.PodRequirements

func N32CpuJobs added in v0.3.69 

func N32CpuJobs(queue string, priorityClassName string, n int) []*jobdb.Job

func N32CpuNodes added in v0.3.69 

func N32CpuNodes(n int, priorities []int32) []*schedulerobjects.Node

func N32CpuPodReqs added in v0.3.69 

func N32CpuPodReqs(queue string, priority int32, n int) []*schedulerobjects.PodRequirements

func N8GpuNodes added in v0.3.69 

func N8GpuNodes(n int, priorities []int32) []*schedulerobjects.Node

func NTainted32CpuNodes added in v0.3.69 

func NTainted32CpuNodes(n int, priorities []int32) []*schedulerobjects.Node

func Repeat 

func Repeat[T any](v T, n int) []T

func Test16CpuJob added in v0.3.69 

func Test16CpuJob(queue string, priorityClassName string) *jobdb.Job

func Test16CpuPodReqs added in v0.3.69 

func Test16CpuPodReqs(queue string, jobId ulid.ULID, priority int32) *schedulerobjects.PodRequirements

func Test1CpuJob added in v0.3.69 

func Test1CpuJob(queue string, priorityClassName string) *jobdb.Job

func Test1CpuPodReqs added in v0.3.69 

func Test1CpuPodReqs(queue string, jobId ulid.ULID, priority int32) *schedulerobjects.PodRequirements

func Test1GpuJob added in v0.3.69 

func Test1GpuJob(queue string, priorityClassName string) *jobdb.Job

func Test1GpuPodReqs added in v0.3.69 

func Test1GpuPodReqs(queue string, jobId ulid.ULID, priority int32) *schedulerobjects.PodRequirements

func Test1Node32CoreExecutor added in v0.3.69 

func Test1Node32CoreExecutor(name string) *schedulerobjects.Executor

func Test32CpuJob added in v0.3.69 

func Test32CpuJob(queue string, priorityClassName string) *jobdb.Job

func Test32CpuNode added in v0.3.69 

func Test32CpuNode(priorities []int32) *schedulerobjects.Node

func Test32CpuPodReqs added in v0.3.69 

func Test32CpuPodReqs(queue string, jobId ulid.ULID, priority int32) *schedulerobjects.PodRequirements

func Test8GpuNode added in v0.3.69 

func Test8GpuNode(priorities []int32) *schedulerobjects.Node

func TestCluster 

func TestCluster() []*schedulerobjects.Node

func TestDbQueue 

func TestDbQueue() *database.Queue

func TestJob added in v0.3.69 

func TestJob(queue string, jobId ulid.ULID, priorityClassName string, req *schedulerobjects.PodRequirements) *jobdb.Job

func TestNode added in v0.3.69 

func TestNode(priorities []int32, resources map[string]resource.Quantity) *schedulerobjects.Node

func TestPodReqs added in v0.3.69 

func TestPodReqs(queue string, jobId ulid.ULID, priority int32, requests v1.ResourceList) *schedulerobjects.PodRequirements

func TestQueuedJobDbJob 

func TestQueuedJobDbJob() *jobdb.Job

func TestRunningJobDbJob 

func TestRunningJobDbJob(startTime int64) *jobdb.Job

func TestSchedulingConfig 

func TestSchedulingConfig() configuration.SchedulingConfig

func TestTainted32CpuNode added in v0.3.69 

func TestTainted32CpuNode(priorities []int32) *schedulerobjects.Node

func TestUnitReqs 

func TestUnitReqs(priority int32) *schedulerobjects.PodRequirements

func WithAnnotationsJobs 

func WithAnnotationsJobs(annotations map[string]string, jobs []*jobdb.Job) []*jobdb.Job

func WithAnnotationsPodReqs 

func WithAnnotationsPodReqs(annotations map[string]string, reqs []*schedulerobjects.PodRequirements) []*schedulerobjects.PodRequirements

func WithGangAnnotationsJobs 

func WithGangAnnotationsJobs(jobs []*jobdb.Job) []*jobdb.Job

func WithGangAnnotationsPodReqs 

func WithGangAnnotationsPodReqs(reqs []*schedulerobjects.PodRequirements) []*schedulerobjects.PodRequirements

func WithIndexedNodeLabelsConfig 

func WithIndexedNodeLabelsConfig(indexedNodeLabels []string, config configuration.SchedulingConfig) configuration.SchedulingConfig

func WithIndexedResourcesConfig added in v0.3.71 

func WithIndexedResourcesConfig(indexResources []configuration.IndexedResource, config configuration.SchedulingConfig) configuration.SchedulingConfig

func WithIndexedTaintsConfig 

func WithIndexedTaintsConfig(indexedTaints []string, config configuration.SchedulingConfig) configuration.SchedulingConfig

func WithJobDbJobPodRequirements 

func WithJobDbJobPodRequirements(job *jobdb.Job, reqs *schedulerobjects.PodRequirements) *jobdb.Job

func WithLabelsNodes 

func WithLabelsNodes(labels map[string]string, nodes []*schedulerobjects.Node) []*schedulerobjects.Node

func WithLastUpdateTimeExecutor added in v0.3.70 

func WithLastUpdateTimeExecutor(lastUpdateTime time.Time, executor *schedulerobjects.Executor) *schedulerobjects.Executor

func WithMaxGangsToScheduleConfig 

func WithMaxGangsToScheduleConfig(n uint, config configuration.SchedulingConfig) configuration.SchedulingConfig

func WithMaxJobsToScheduleConfig 

func WithMaxJobsToScheduleConfig(n uint, config configuration.SchedulingConfig) configuration.SchedulingConfig

func WithMaxLookbackPerQueueConfig 

func WithMaxLookbackPerQueueConfig(n uint, config configuration.SchedulingConfig) configuration.SchedulingConfig

func WithMaxQueueLookbackConfig added in v0.3.66 

func WithMaxQueueLookbackConfig(maxQueueLookback uint, config configuration.SchedulingConfig) configuration.SchedulingConfig

func WithMaxUnacknowledgedJobsPerExecutor 

func WithMaxUnacknowledgedJobsPerExecutor(i uint, config configuration.SchedulingConfig) configuration.SchedulingConfig

func WithNodeAffinityPodReqs 

func WithNodeAffinityPodReqs(nodeSelectorTerms []v1.NodeSelectorTerm, reqs []*schedulerobjects.PodRequirements) []*schedulerobjects.PodRequirements

func WithNodeEvictionProbabilityConfig 

func WithNodeEvictionProbabilityConfig(p float64, config configuration.SchedulingConfig) configuration.SchedulingConfig

func WithNodeOversubscriptionEvictionProbabilityConfig 

func WithNodeOversubscriptionEvictionProbabilityConfig(p float64, config configuration.SchedulingConfig) configuration.SchedulingConfig

func WithNodeSelectorJobs 

func WithNodeSelectorJobs(selector map[string]string, jobs []*jobdb.Job) []*jobdb.Job

func WithNodeSelectorPodReq 

func WithNodeSelectorPodReq(selector map[string]string, req *schedulerobjects.PodRequirements) *schedulerobjects.PodRequirements

func WithNodeSelectorPodReqs 

func WithNodeSelectorPodReqs(selector map[string]string, reqs []*schedulerobjects.PodRequirements) []*schedulerobjects.PodRequirements

func WithNodeTypeIdNodes 

func WithNodeTypeIdNodes(nodeTypeId uint64, nodes []*schedulerobjects.Node) []*schedulerobjects.Node

func WithPerPriorityLimitsConfig 

func WithPerPriorityLimitsConfig(limits map[int32]map[string]float64, config configuration.SchedulingConfig) configuration.SchedulingConfig

func WithRequestsPodReqs 

func WithRequestsPodReqs(rl schedulerobjects.ResourceList, reqs []*schedulerobjects.PodRequirements) []*schedulerobjects.PodRequirements

func WithRoundLimitsConfig 

func WithRoundLimitsConfig(limits map[string]float64, config configuration.SchedulingConfig) configuration.SchedulingConfig

func WithRoundLimitsPoolConfig added in v0.3.66 

func WithRoundLimitsPoolConfig(limits map[string]map[string]float64, config configuration.SchedulingConfig) configuration.SchedulingConfig

func WithUsedResourcesNodes 

func WithUsedResourcesNodes(p int32, rl schedulerobjects.ResourceList, nodes []*schedulerobjects.Node) []*schedulerobjects.Node

Types

This section is empty.

Source Files

View all Source files

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.