Versions in this module Expand all Collapse all v0 v0.27.1 Jul 30, 2020 v0.27.0 Jul 14, 2020 Changes in this version + var DefaultGracefulStopValue = 30 * time.Second + func DeriveScenariosFromShortcuts(opts lib.Options) (lib.Options, error) + type BaseConfig struct + Env map[string]string + Exec null.String + GracefulStop types.NullDuration + Name string + StartTime types.NullDuration + Tags map[string]string + Type string + func NewBaseConfig(name, configType string) BaseConfig + func (bc BaseConfig) GetEnv() map[string]string + func (bc BaseConfig) GetExec() string + func (bc BaseConfig) GetGracefulStop() time.Duration + func (bc BaseConfig) GetName() string + func (bc BaseConfig) GetStartTime() time.Duration + func (bc BaseConfig) GetTags() map[string]string + func (bc BaseConfig) GetType() string + func (bc BaseConfig) IsDistributable() bool + func (bc BaseConfig) Validate() (errors []error) + type BaseExecutor struct + func NewBaseExecutor(config lib.ExecutorConfig, es *lib.ExecutionState, logger *logrus.Entry) *BaseExecutor + func (bs *BaseExecutor) Init(_ context.Context) error + func (bs BaseExecutor) GetConfig() lib.ExecutorConfig + func (bs BaseExecutor) GetLogger() *logrus.Entry + func (bs BaseExecutor) GetProgress() *pb.ProgressBar + type ConstantArrivalRate struct + func (car *ConstantArrivalRate) Init(ctx context.Context) error + func (car ConstantArrivalRate) Run(parentCtx context.Context, out chan<- stats.SampleContainer) (err error) + type ConstantArrivalRateConfig struct + Duration types.NullDuration + MaxVUs null.Int + PreAllocatedVUs null.Int + Rate null.Int + TimeUnit types.NullDuration + func NewConstantArrivalRateConfig(name string) *ConstantArrivalRateConfig + func (carc *ConstantArrivalRateConfig) Validate() []error + func (carc ConstantArrivalRateConfig) GetDescription(et *lib.ExecutionTuple) string + func (carc ConstantArrivalRateConfig) GetExecutionRequirements(et *lib.ExecutionTuple) []lib.ExecutionStep + func (carc ConstantArrivalRateConfig) GetMaxVUs(et *lib.ExecutionTuple) int64 + func (carc ConstantArrivalRateConfig) GetPreAllocatedVUs(et *lib.ExecutionTuple) int64 + func (carc ConstantArrivalRateConfig) HasWork(et *lib.ExecutionTuple) bool + func (carc ConstantArrivalRateConfig) NewExecutor(es *lib.ExecutionState, logger *logrus.Entry) (lib.Executor, error) + type ConstantVUs struct + func (clv ConstantVUs) Run(parentCtx context.Context, out chan<- stats.SampleContainer) (err error) + type ConstantVUsConfig struct + Duration types.NullDuration + VUs null.Int + func NewConstantVUsConfig(name string) ConstantVUsConfig + func (clvc ConstantVUsConfig) GetDescription(et *lib.ExecutionTuple) string + func (clvc ConstantVUsConfig) GetExecutionRequirements(et *lib.ExecutionTuple) []lib.ExecutionStep + func (clvc ConstantVUsConfig) GetVUs(et *lib.ExecutionTuple) int64 + func (clvc ConstantVUsConfig) HasWork(et *lib.ExecutionTuple) bool + func (clvc ConstantVUsConfig) NewExecutor(es *lib.ExecutionState, logger *logrus.Entry) (lib.Executor, error) + func (clvc ConstantVUsConfig) Validate() []error + type ExecutionConflictError string + func (e ExecutionConflictError) Error() string + type ExternallyControlled struct + func (mex *ExternallyControlled) GetConfig() lib.ExecutorConfig + func (mex *ExternallyControlled) GetCurrentConfig() ExternallyControlledConfig + func (mex *ExternallyControlled) Run(parentCtx context.Context, out chan<- stats.SampleContainer) (err error) + func (mex *ExternallyControlled) SetPaused(paused bool) error + func (mex *ExternallyControlled) UpdateConfig(ctx context.Context, newConf interface{}) error + func (mex ExternallyControlled) GetLogger() *logrus.Entry + func (mex ExternallyControlled) GetProgress() *pb.ProgressBar + func (mex ExternallyControlled) Init(ctx context.Context) error + type ExternallyControlledConfig struct + func (ExternallyControlledConfig) IsDistributable() bool + func (mec ExternallyControlledConfig) GetDescription(_ *lib.ExecutionTuple) string + func (mec ExternallyControlledConfig) GetExecutionRequirements(et *lib.ExecutionTuple) []lib.ExecutionStep + func (mec ExternallyControlledConfig) HasWork(_ *lib.ExecutionTuple) bool + func (mec ExternallyControlledConfig) NewExecutor(es *lib.ExecutionState, logger *logrus.Entry) (lib.Executor, error) + func (mec ExternallyControlledConfig) Validate() []error + type ExternallyControlledConfigParams struct + Duration types.NullDuration + MaxVUs null.Int + VUs null.Int + func (mecc ExternallyControlledConfigParams) Validate() (errors []error) + type PerVUIterations struct + func (pvi PerVUIterations) Run(parentCtx context.Context, out chan<- stats.SampleContainer) (err error) + type PerVUIterationsConfig struct + Iterations null.Int + MaxDuration types.NullDuration + VUs null.Int + func NewPerVUIterationsConfig(name string) PerVUIterationsConfig + func (pvic PerVUIterationsConfig) GetDescription(et *lib.ExecutionTuple) string + func (pvic PerVUIterationsConfig) GetExecutionRequirements(et *lib.ExecutionTuple) []lib.ExecutionStep + func (pvic PerVUIterationsConfig) GetIterations() int64 + func (pvic PerVUIterationsConfig) GetVUs(et *lib.ExecutionTuple) int64 + func (pvic PerVUIterationsConfig) HasWork(et *lib.ExecutionTuple) bool + func (pvic PerVUIterationsConfig) NewExecutor(es *lib.ExecutionState, logger *logrus.Entry) (lib.Executor, error) + func (pvic PerVUIterationsConfig) Validate() []error + type RampingArrivalRate struct + func (varr RampingArrivalRate) Run(parentCtx context.Context, out chan<- stats.SampleContainer) (err error) + type RampingArrivalRateConfig struct + MaxVUs null.Int + PreAllocatedVUs null.Int + Stages []Stage + StartRate null.Int + TimeUnit types.NullDuration + func NewRampingArrivalRateConfig(name string) *RampingArrivalRateConfig + func (varc *RampingArrivalRateConfig) Validate() []error + func (varc RampingArrivalRateConfig) GetDescription(et *lib.ExecutionTuple) string + func (varc RampingArrivalRateConfig) GetExecutionRequirements(et *lib.ExecutionTuple) []lib.ExecutionStep + func (varc RampingArrivalRateConfig) GetMaxVUs(et *lib.ExecutionTuple) int64 + func (varc RampingArrivalRateConfig) GetPreAllocatedVUs(et *lib.ExecutionTuple) int64 + func (varc RampingArrivalRateConfig) HasWork(et *lib.ExecutionTuple) bool + func (varc RampingArrivalRateConfig) NewExecutor(es *lib.ExecutionState, logger *logrus.Entry) (lib.Executor, error) + type RampingVUs struct + func (vlv RampingVUs) Run(parentCtx context.Context, out chan<- stats.SampleContainer) (err error) + type RampingVUsConfig struct + GracefulRampDown types.NullDuration + Stages []Stage + StartVUs null.Int + func NewRampingVUsConfig(name string) RampingVUsConfig + func (vlvc RampingVUsConfig) GetDescription(et *lib.ExecutionTuple) string + func (vlvc RampingVUsConfig) GetExecutionRequirements(et *lib.ExecutionTuple) []lib.ExecutionStep + func (vlvc RampingVUsConfig) GetGracefulRampDown() time.Duration + func (vlvc RampingVUsConfig) GetStartVUs(et *lib.ExecutionTuple) int64 + func (vlvc RampingVUsConfig) HasWork(et *lib.ExecutionTuple) bool + func (vlvc RampingVUsConfig) NewExecutor(es *lib.ExecutionState, logger *logrus.Entry) (lib.Executor, error) + func (vlvc RampingVUsConfig) Validate() []error + type SharedIterations struct + func (si *SharedIterations) Init(ctx context.Context) error + func (si SharedIterations) Run(parentCtx context.Context, out chan<- stats.SampleContainer) (err error) + type SharedIterationsConfig struct + Iterations null.Int + MaxDuration types.NullDuration + VUs null.Int + func NewSharedIterationsConfig(name string) SharedIterationsConfig + func (sic SharedIterationsConfig) GetDescription(et *lib.ExecutionTuple) string + func (sic SharedIterationsConfig) GetExecutionRequirements(et *lib.ExecutionTuple) []lib.ExecutionStep + func (sic SharedIterationsConfig) GetIterations(et *lib.ExecutionTuple) int64 + func (sic SharedIterationsConfig) GetVUs(et *lib.ExecutionTuple) int64 + func (sic SharedIterationsConfig) HasWork(et *lib.ExecutionTuple) bool + func (sic SharedIterationsConfig) NewExecutor(es *lib.ExecutionState, logger *logrus.Entry) (lib.Executor, error) + func (sic SharedIterationsConfig) Validate() []error + type Stage struct + Duration types.NullDuration + Target null.Int
Go to main page