Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

executor

package

Go to main page

Versions in this module

v0

v0.33.0

Apr 29, 2021

v0.32.0

Apr 29, 2021

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