configuration

package
v0.20.39 Latest Latest
Warning

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

Go to latest
Published: Apr 10, 2026 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ActionsConfig

type ActionsConfig struct {
	JobSetReprioritisations []JobSetReprioritisation `yaml:"jobSetReprioritisations"`
	JobSetCancellations     []JobSetCancellation     `yaml:"jobSetCancellations"`
}

func (*ActionsConfig) Validate

func (a *ActionsConfig) Validate(testDuration interface{}) error

Validate validates the ActionsConfig configuration.

type DatabaseConfig

type DatabaseConfig struct {
	Postgres                map[string]string `yaml:"postgres,omitempty"`
	ClickHouse              map[string]string `yaml:"clickHouse,omitempty"`
	InMemory                bool              `yaml:"inMemory,omitempty"`
	PostgresTuningSQL       []string          `yaml:"postgresTuningSQL,omitempty"`
	PostgresTuningRevertSQL []string          `yaml:"postgresTuningRevertSQL,omitempty"`
}

func (*DatabaseConfig) Mutate added in v0.20.35

func (d *DatabaseConfig) Mutate() (commonconfig.Config, error)

func (*DatabaseConfig) Validate

func (d *DatabaseConfig) Validate() error

Validate validates the DatabaseConfig configuration.

type FeatureToggles added in v0.20.37

type FeatureToggles struct {
	HotColdSplit bool `yaml:"hotColdSplit,omitempty"`
}

type HistoricalJobsConfig

type HistoricalJobsConfig struct {
	NumberOfJobs        int     `yaml:"numberOfJobs"`
	ProportionSucceeded float64 `yaml:"proportionSucceeded"`
	ProportionErrored   float64 `yaml:"proportionErrored"`
	ProportionCancelled float64 `yaml:"proportionCancelled"`
	ProportionPreempted float64 `yaml:"proportionPreempted"`
	JobAgeDays          []int   `yaml:"jobAgeDays"`
}

func (*HistoricalJobsConfig) Mutate added in v0.20.35

func (*HistoricalJobsConfig) Validate

func (h *HistoricalJobsConfig) Validate() error

Validate validates the HistoricalJobsConfig configuration.

type IngestionConfig

type IngestionConfig struct {
	BatchSize                   int                      `yaml:"batchSize"`
	NumWorkers                  int                      `yaml:"numWorkers"`
	SubmissionsPerHour          int                      `yaml:"submissionsPerHour"`
	ChannelBufferSizeMultiplier int                      `yaml:"channelBufferSizeMultiplier,omitempty"`
	MaxBacklogSize              int                      `yaml:"maxBacklogSize,omitempty"`
	BacklogDropStrategy         string                   `yaml:"backlogDropStrategy,omitempty"`
	BatchTimeout                time.Duration            `yaml:"batchTimeout,omitempty"`
	HistoricalJobChunkSize      int                      `yaml:"historicalJobChunkSize,omitempty"`
	HistoricalJobWorkers        int                      `yaml:"historicalJobWorkers,omitempty"`
	JobStateTransitionConfig    JobStateTransitionConfig `yaml:"jobStateTransitionConfig"`
}

func (*IngestionConfig) Mutate added in v0.20.35

func (i *IngestionConfig) Mutate() (commonconfig.Config, error)

func (*IngestionConfig) Validate

func (i *IngestionConfig) Validate() error

Validate validates the IngestionConfig configuration.

type JobSetCancellation

type JobSetCancellation struct {
	PerformAfterTestStartTime time.Duration `yaml:"performAfterTestStartTime"`
	Queue                     string        `yaml:"queue"`
	JobSet                    string        `yaml:"jobSet"`
}

func (*JobSetCancellation) Validate

func (j *JobSetCancellation) Validate(testDurationNano int64) error

Validate validates the JobSetCancellation configuration.

type JobSetConfig

type JobSetConfig struct {
	Name                 string               `yaml:"name"`
	Proportion           float64              `yaml:"proportion"`
	HistoricalJobsConfig HistoricalJobsConfig `yaml:"historicalJobsConfig"`
}

func (*JobSetConfig) Mutate added in v0.20.35

func (j *JobSetConfig) Mutate() (commonconfig.Config, error)

func (*JobSetConfig) Validate

func (j *JobSetConfig) Validate() error

Validate validates the JobSetConfig configuration.

type JobSetReprioritisation

type JobSetReprioritisation struct {
	PerformAfterTestStartTime time.Duration `yaml:"performAfterTestStartTime"`
	Queue                     string        `yaml:"queue"`
	JobSet                    string        `yaml:"jobSet"`
}

func (*JobSetReprioritisation) Validate

func (j *JobSetReprioritisation) Validate(testDurationNano int64) error

Validate validates the JobSetReprioritisation configuration.

type JobStateTransitionConfig

type JobStateTransitionConfig struct {
	QueueingDuration         time.Duration `yaml:"queueingDuration"`
	LeasedDuration           time.Duration `yaml:"leasedDuration"`
	PendingDuration          time.Duration `yaml:"pendingDuration"`
	ProportionSucceed        float64       `yaml:"proportionSucceed"`
	RunningToSuccessDuration time.Duration `yaml:"runningToSuccessDuration"`
	ProportionFail           float64       `yaml:"proportionFail"`
	RunningToFailureDuration time.Duration `yaml:"runningToFailureDuration"`
}

func (*JobStateTransitionConfig) Mutate added in v0.20.35

func (*JobStateTransitionConfig) Validate

func (j *JobStateTransitionConfig) Validate() error

Validate validates the JobStateTransitionConfig configuration.

type QueryConfig

type QueryConfig struct {
	GetJobRunDebugMessageQueriesPerHour int `yaml:"getJobRunDebugMessageQueriesPerHour"`
	GetJobRunErrorQueriesPerHour        int `yaml:"getJobRunErrorQueriesPerHour"`
	GetJobSpecQueriesPerHour            int `yaml:"getJobSpecQueriesPerHour"`
	GetJobsQueriesPerHour               int `yaml:"getJobsQueriesPerHour"`
	GetJobsPageSize                     int `yaml:"getJobsPageSize"`
	GetJobGroupsQueriesPerHour          int `yaml:"getJobGroupsQueriesPerHour"`
	GetJobGroupsPageSize                int `yaml:"getJobGroupsPageSize"`
	MaxConcurrentQueries                int `yaml:"maxConcurrentQueries,omitempty"`
	MaxErrorsToCollect                  int `yaml:"maxErrorsToCollect,omitempty"`
}

func (*QueryConfig) Mutate added in v0.20.35

func (q *QueryConfig) Mutate() (commonconfig.Config, error)

func (*QueryConfig) Validate

func (q *QueryConfig) Validate() error

Validate validates the QueryConfig configuration.

type QueueConfig

type QueueConfig struct {
	Name         string         `yaml:"name"`
	Proportion   float64        `yaml:"proportion"`
	JobSetConfig []JobSetConfig `yaml:"jobSetConfig"`
}

func (*QueueConfig) Mutate added in v0.20.35

func (q *QueueConfig) Mutate() (commonconfig.Config, error)

func (*QueueConfig) Validate

func (q *QueueConfig) Validate() error

Validate validates the QueueConfig configuration.

type TestConfig

type TestConfig struct {
	FeatureToggles  FeatureToggles  `yaml:"featureToggles,omitempty"`
	TestDuration    time.Duration   `yaml:"testDuration"`
	WarmupDuration  time.Duration   `yaml:"warmupDuration"`
	SkipTearDown    bool            `yaml:"skipTearDown,omitempty"`
	DatabaseConfig  DatabaseConfig  `yaml:"databaseConfig"`
	QueueConfig     []QueueConfig   `yaml:"queueConfig"`
	IngestionConfig IngestionConfig `yaml:"ingestionConfig"`
	QueryConfig     QueryConfig     `yaml:"queryConfig"`
	ActionsConfig   ActionsConfig   `yaml:"actionsConfig"`
}

func (*TestConfig) Mutate added in v0.20.35

func (t *TestConfig) Mutate() (commonconfig.Config, error)

func (*TestConfig) Validate

func (t *TestConfig) Validate() error

Validate validates the Test configuration.

Jump to

Keyboard shortcuts

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