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 (h *HistoricalJobsConfig) Mutate() (commonconfig.Config, error)
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 (j *JobStateTransitionConfig) Mutate() (commonconfig.Config, error)
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.
Click to show internal directories.
Click to hide internal directories.