batchtest

Documentation

Index

• func BatchTest(ctr *app.Container) error
• type BatchSleep
• type BatchSleepValue
• type BatchTestOutput
• type BatchTestType
  • func (b BatchTestType) RetrieveSleepValue(after SleepAfterValue) (time.Duration, bool)
• type PipelineConfig
• type PipelineFileConfig
• type PipelineFileThreadOnlyValue
• type SleepAfterValue

Functions

func BatchTest

func BatchTest(ctr *app.Container) error

Types

type BatchSleep

type BatchSleep struct {
	Enabled bool              `yaml:"enabled"`
	Values  []BatchSleepValue `yaml:"values"`
}

type BatchSleepValue

type BatchSleepValue struct {
	Duration string
	After    string // init, prefetch, replace, metricsBoot, request
}

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 PipelineFileThreadOnlyValue

type PipelineFileThreadOnlyValue struct {
	Key   string `yaml:"key"`
	Value string `yaml:"value"`
}

type SleepAfterValue

type SleepAfterValue string

const (
	SleepAfterInit        SleepAfterValue = "init"
	SleepAfterPrefetch    SleepAfterValue = "prefetch"
	SleepAfterReplace     SleepAfterValue = "replace"
	SleepAfterMetrics     SleepAfterValue = "metricsBoot"
	SleepAfterSuccessExec SleepAfterValue = "successExec"
	SleepAfterFailedExec  SleepAfterValue = "failedExec"
)