Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type BatchSleep ¶
type BatchSleep struct {
Enabled bool `yaml:"enabled"`
Values []BatchSleepValue `yaml:"values"`
}
type BatchSleepValue ¶
type BatchTestOutput ¶
type BatchTestOutput struct {
Enabled bool `yaml:"enabled"`
}
type BatchTestType ¶
type BatchTestType struct {
Type string `yaml:"type"`
Sleep BatchSleep `yaml:"sleep"`
Prefetch prefetchbatch.PrefetchConfig `yaml:"prefetch"`
Metrics metricsbatch.MetricsBatchConfig `yaml:"metrics"`
Data any `yaml:"data"`
Output BatchTestOutput `yaml:"output"`
}
func (BatchTestType) RetrieveSleepValue ¶
func (b BatchTestType) RetrieveSleepValue(after SleepAfterValue) (time.Duration, bool)
type PipelineConfig ¶
type PipelineConfig struct {
Type string `yaml:"type"`
Concurrency int `yaml:"concurrency"`
Files []PipelineFileConfig `yaml:"files"`
}
type PipelineFileConfig ¶
type PipelineFileConfig struct {
ID string `yaml:"id"`
File string `yaml:"file"`
Count int `yaml:"count"`
NoLoopOverride bool `yaml:"noLoopOverride"`
ThreadOnlyValues []PipelineFileThreadOnlyValue `yaml:"threadOnlyValues"`
}
type SleepAfterValue ¶
type SleepAfterValue string
const ( SleepAfterInit SleepAfterValue = "init" SleepAfterPrefetch SleepAfterValue = "prefetch" SleepAfterReplace SleepAfterValue = "replace" SleepAfterMetrics SleepAfterValue = "metricsBoot" SleepAfterSuccessExec SleepAfterValue = "successExec" SleepAfterFailedExec SleepAfterValue = "failedExec" )
Click to show internal directories.
Click to hide internal directories.