local

Documentation

Index

• func ProcessStages(startVUs int64, stages []lib.Stage, t time.Duration) (null.Int, bool)
• type Executor
  • func New(r lib.Runner) *Executor
  • func (e *Executor) GetEndIterations() null.Int
  • func (e *Executor) GetEndTime() types.NullDuration
  • func (e *Executor) GetIterations() int64
  • func (e *Executor) GetLogger() *logrus.Logger
  • func (e *Executor) GetRunner() lib.Runner
  • func (e *Executor) GetStages() []lib.Stage
  • func (e *Executor) GetTime() time.Duration
  • func (e *Executor) GetVUs() int64
  • func (e *Executor) GetVUsMax() int64
  • func (e *Executor) IsPaused() bool
  • func (e *Executor) IsRunning() bool
  • func (e *Executor) Run(parent context.Context, engineOut chan<- stats.SampleContainer) (reterr error)
  • func (e *Executor) SetEndIterations(i null.Int)
  • func (e *Executor) SetEndTime(t types.NullDuration)
  • func (e *Executor) SetLogger(l *logrus.Logger)
  • func (e *Executor) SetPaused(paused bool)
  • func (e *Executor) SetRunSetup(r bool)
  • func (e *Executor) SetRunTeardown(r bool)
  • func (e *Executor) SetStages(s []lib.Stage)
  • func (e *Executor) SetVUs(num int64) error
  • func (e *Executor) SetVUsMax(max int64) error

Functions

func ProcessStages

func ProcessStages(startVUs int64, stages []lib.Stage, t time.Duration) (null.Int, bool)

Returns the VU count and whether to keep going at the specified time.

Types

type Executor

type Executor struct {
	Runner lib.Runner
	Logger *logrus.Logger
	// contains filtered or unexported fields
}

func New

func New(r lib.Runner) *Executor

func (*Executor) GetEndIterations

func (e *Executor) GetEndIterations() null.Int

func (*Executor) GetEndTime

func (e *Executor) GetEndTime() types.NullDuration

func (*Executor) GetIterations

func (e *Executor) GetIterations() int64

func (*Executor) GetLogger

func (e *Executor) GetLogger() *logrus.Logger

GetLogger returns current Executor's logger.

func (*Executor) GetRunner

func (e *Executor) GetRunner() lib.Runner

func (*Executor) GetStages

func (e *Executor) GetStages() []lib.Stage

func (*Executor) GetTime

func (e *Executor) GetTime() time.Duration

func (*Executor) GetVUs

func (e *Executor) GetVUs() int64

func (*Executor) GetVUsMax

func (e *Executor) GetVUsMax() int64

func (*Executor) IsPaused

func (e *Executor) IsPaused() bool

func (*Executor) IsRunning

func (e *Executor) IsRunning() bool

func (*Executor) Run

func (e *Executor) Run(parent context.Context, engineOut chan<- stats.SampleContainer) (reterr error)

func (*Executor) SetEndIterations

func (e *Executor) SetEndIterations(i null.Int)

func (*Executor) SetEndTime

func (e *Executor) SetEndTime(t types.NullDuration)

func (*Executor) SetLogger

func (e *Executor) SetLogger(l *logrus.Logger)

SetLogger sets Executor's logger.

func (*Executor) SetPaused

func (e *Executor) SetPaused(paused bool)

func (*Executor) SetRunSetup

func (e *Executor) SetRunSetup(r bool)

func (*Executor) SetRunTeardown

func (e *Executor) SetRunTeardown(r bool)

func (*Executor) SetStages

func (e *Executor) SetStages(s []lib.Stage)

func (*Executor) SetVUs

func (e *Executor) SetVUs(num int64) error

func (*Executor) SetVUsMax

func (e *Executor) SetVUsMax(max int64) error