local

Documentation

Index

• func ProcessStages(startVUs int64, stages []lib.Stage, t time.Duration) (null.Int, bool)
• func SumStages(stages []lib.Stage) (d lib.NullDuration)
• type Executor
  • func New(r lib.Runner) *Executor
  • func (e *Executor) GetEndIterations() null.Int
  • func (e *Executor) GetEndTime() lib.NullDuration
  • func (e *Executor) GetIterations() int64
  • func (e *Executor) GetLogger() *log.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, out chan<- []stats.Sample) error
  • func (e *Executor) SetEndIterations(i null.Int)
  • func (e *Executor) SetEndTime(t lib.NullDuration)
  • func (e *Executor) SetLogger(l *log.Logger)
  • func (e *Executor) SetPaused(paused 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.

func SumStages

func SumStages(stages []lib.Stage) (d lib.NullDuration)

Returns the total sum of time taken by the given set of stages.

Types

type Executor

type Executor struct {
	Runner lib.Runner
	Logger *log.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() lib.NullDuration

func (*Executor) GetIterations

func (e *Executor) GetIterations() int64

func (*Executor) GetLogger

func (e *Executor) GetLogger() *log.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, out chan<- []stats.Sample) error

func (*Executor) SetEndIterations

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

func (*Executor) SetEndTime

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

func (*Executor) SetLogger

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

func (*Executor) SetPaused

func (e *Executor) SetPaused(paused 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