testfixtures

package
v0.3.75-rc-00397cf 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 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 WithMaxQueueLookbackConfig added in v0.3.66

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

func WithNodeAffinityPodReqs

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

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 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 WithRoundLimitsPoolConfig added in v0.3.66

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

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL