run

Documentation

Index

• Constants
• func Cmd(s *scenarios.Scenarios, builders []api.Builder, ...) *cobra.Command
• type ActiveScenario
  • func NewActiveScenario(scenario *scenarios.Scenario) (*ActiveScenario, bool)
  • func (s *ActiveScenario) RecordDroppedIteration()
  • func (s *ActiveScenario) Run(metric metrics.MetricType, stage, iter string, f func(t *testing.T)) bool
• type CancellableTimer
  • func NewCancellableTimer(d time.Duration) *CancellableTimer
  • func (c *CancellableTimer) Cancel() bool
  • func (c *CancellableTimer) Reset(duration time.Duration)
• type DurationPercentileMap
  • func (m *DurationPercentileMap) Get(pc float64) string
  • func (m *DurationPercentileMap) String() string
• type Run
  • func NewRun(options options.RunOptions, t *api.Trigger) (*Run, error)
  • func (r *Run) Do(s *scenarios.Scenarios) *RunResult
• type RunResult
  • func (r *RunResult) AddError(err error) *RunResult
  • func (r *RunResult) ClearProgressMetrics()
  • func (r *RunResult) Duration() time.Duration
  • func (r *RunResult) Error() error
  • func (r *RunResult) Failed() bool
  • func (r *RunResult) IncrementMetrics(duration time.Duration, result string, stage string, count uint64, ...)
  • func (r *RunResult) Interrupted() string
  • func (r *RunResult) Iterations() uint64
  • func (r *RunResult) IterationsStarted() uint64
  • func (r *RunResult) MaxDurationElapsed() string
  • func (r *RunResult) MaxIterationsReached() string
  • func (r *RunResult) Progress() string
  • func (r *RunResult) RecordStarted()
  • func (r *RunResult) RecordTestFinished()
  • func (r *RunResult) SetMetrics(result string, stage string, count uint64, ...)
  • func (r *RunResult) Setup() string
  • func (r *RunResult) StartTime() time.Time
  • func (r *RunResult) String() string
  • func (r *RunResult) Teardown() string

Constants

const IterationStage = "iteration"

const NextIterationWindow = 10 * time.Millisecond

Functions

func Cmd

func Cmd(s *scenarios.Scenarios, builders []api.Builder, hookFunc logging.RegisterLogHookFunc) *cobra.Command

Types

type ActiveScenario

type ActiveScenario struct {
	Teardown func()
	// contains filtered or unexported fields
}

func NewActiveScenario

func NewActiveScenario(scenario *scenarios.Scenario) (*ActiveScenario, bool)

func (*ActiveScenario) RecordDroppedIteration

func (s *ActiveScenario) RecordDroppedIteration()

func (*ActiveScenario) Run

func (s *ActiveScenario) Run(metric metrics.MetricType, stage, iter string, f func(t *testing.T)) bool

Run performs a single iteration of the test. It returns `true` if the test was successful, `false` otherwise.

type CancellableTimer

type CancellableTimer struct {
	C chan bool
	// contains filtered or unexported fields
}

func NewCancellableTimer

func NewCancellableTimer(d time.Duration) *CancellableTimer

func (*CancellableTimer) Cancel

func (c *CancellableTimer) Cancel() bool

Cancel makes all the waiters receive false

func (*CancellableTimer) Reset

func (c *CancellableTimer) Reset(duration time.Duration)

type DurationPercentileMap

type DurationPercentileMap map[float64]time.Duration

func (*DurationPercentileMap) Get

func (m *DurationPercentileMap) Get(pc float64) string

func (*DurationPercentileMap) String

func (m *DurationPercentileMap) String() string

type Run

type Run struct {
	Options options.RunOptions

	RateDescription string
	// contains filtered or unexported fields
}

func NewRun

func NewRun(options options.RunOptions, t *api.Trigger) (*Run, error)

func (*Run) Do

func (r *Run) Do(s *scenarios.Scenarios) *RunResult

type RunResult

type RunResult struct {
	SuccessfulIterationCount     uint64
	SuccessfulIterationDurations DurationPercentileMap
	FailedIterationCount         uint64
	FailedIterationDurations     DurationPercentileMap

	TestDuration               time.Duration
	LogFile                    string
	IgnoreDropped              bool
	DroppedIterationCount      uint64
	RecentSuccessfulIterations uint64
	RecentDuration             time.Duration
	// contains filtered or unexported fields
}

func (*RunResult) AddError

func (r *RunResult) AddError(err error) *RunResult

func (*RunResult) ClearProgressMetrics

func (r *RunResult) ClearProgressMetrics()

func (*RunResult) Duration

func (r *RunResult) Duration() time.Duration

func (*RunResult) Error

func (r *RunResult) Error() error

func (*RunResult) Failed

func (r *RunResult) Failed() bool

func (*RunResult) IncrementMetrics

func (r *RunResult) IncrementMetrics(duration time.Duration, result string, stage string, count uint64, quantiles []*io_prometheus_client.Quantile)

func (*RunResult) Interrupted

func (r *RunResult) Interrupted() string

func (*RunResult) Iterations

func (r *RunResult) Iterations() uint64

func (*RunResult) IterationsStarted

func (r *RunResult) IterationsStarted() uint64

func (*RunResult) MaxDurationElapsed

func (r *RunResult) MaxDurationElapsed() string

func (*RunResult) MaxIterationsReached

func (r *RunResult) MaxIterationsReached() string

func (*RunResult) Progress

func (r *RunResult) Progress() string

func (*RunResult) RecordStarted

func (r *RunResult) RecordStarted()

func (*RunResult) RecordTestFinished

func (r *RunResult) RecordTestFinished()

func (*RunResult) SetMetrics

func (r *RunResult) SetMetrics(result string, stage string, count uint64, quantiles []*io_prometheus_client.Quantile)

func (*RunResult) Setup

func (r *RunResult) Setup() string

func (*RunResult) StartTime

func (r *RunResult) StartTime() time.Time

func (*RunResult) String

func (r *RunResult) String() string

func (*RunResult) Teardown

func (r *RunResult) Teardown() string