lib

Jul 14, 2020

Changes in this version

+ const DefaultScenarioName

+ const MaxRetriesGetPlannedVU

+ const MaxTimeToWaitForPlannedVU

+ func ConcatErrors(errors []error, separator string) string

+ func GetEndOffset(steps []ExecutionStep) (lastStepOffset time.Duration, isFinal bool)

+ func GetMaxPlannedVUs(steps []ExecutionStep) (result uint64)

+ func GetMaxPossibleVUs(steps []ExecutionStep) (result uint64)

+ func RegisterExecutorConfigType(configType string, constructor ExecutorConfigConstructor)

+ func StrictJSONUnmarshal(data []byte, v interface{}) error

+ type ActiveVU interface

+ RunOnce func() error

+ type CompatibilityMode uint8

+ const CompatibilityModeBase

+ const CompatibilityModeExtended

+ func CompatibilityModeString(s string) (CompatibilityMode, error)

+ func CompatibilityModeValues() []CompatibilityMode

+ func (i CompatibilityMode) IsACompatibilityMode() bool

+ func (i CompatibilityMode) String() string

+ type ExecutionScheduler interface

+ GetExecutors func() []Executor

+ GetRunner func() Runner

+ GetState func() *ExecutionState

+ Init func(ctx context.Context, samplesOut chan<- stats.SampleContainer) error

+ Run func(globalCtx, runCtx context.Context, samplesOut chan<- stats.SampleContainer) error

+ SetPaused func(paused bool) error

+ type ExecutionSegment struct

+ func NewExecutionSegment(from, to *big.Rat) (*ExecutionSegment, error)

+ func NewExecutionSegmentFromString(toStr string) (result *ExecutionSegment, err error)

+ func (es *ExecutionSegment) CopyScaleRat(value *big.Rat) *big.Rat

+ func (es *ExecutionSegment) Equal(other *ExecutionSegment) bool

+ func (es *ExecutionSegment) FloatLength() float64

+ func (es *ExecutionSegment) InPlaceScaleRat(value *big.Rat) *big.Rat

+ func (es *ExecutionSegment) MarshalText() ([]byte, error)

+ func (es *ExecutionSegment) Scale(value int64) int64

+ func (es *ExecutionSegment) Split(numParts int64) ([]*ExecutionSegment, error)

+ func (es *ExecutionSegment) String() string

+ func (es *ExecutionSegment) SubSegment(child *ExecutionSegment) *ExecutionSegment

+ func (es *ExecutionSegment) UnmarshalText(text []byte) (err error)

+ type ExecutionSegmentSequence []*ExecutionSegment

+ func GetFilledExecutionSegmentSequence(sequence *ExecutionSegmentSequence, fallback *ExecutionSegment) (result ExecutionSegmentSequence)

+ func NewExecutionSegmentSequence(segments ...*ExecutionSegment) (ExecutionSegmentSequence, error)

+ func NewExecutionSegmentSequenceFromString(strSeq string) (ExecutionSegmentSequence, error)

+ func (ess *ExecutionSegmentSequence) UnmarshalText(text []byte) (err error)

+ func (ess ExecutionSegmentSequence) FindSegmentPosition(segment *ExecutionSegment) (int, error)

+ func (ess ExecutionSegmentSequence) IsFull() bool

+ func (ess ExecutionSegmentSequence) LCD() int64

+ func (ess ExecutionSegmentSequence) MarshalText() ([]byte, error)

+ func (ess ExecutionSegmentSequence) String() string

+ type ExecutionSegmentSequenceWrapper struct

+ func NewExecutionSegmentSequenceWrapper(ess ExecutionSegmentSequence) *ExecutionSegmentSequenceWrapper

+ func (essw *ExecutionSegmentSequenceWrapper) GetNewExecutionSegmentSequenceFromValue(value int64, trackedIndex int) (newSequence *ExecutionSegmentSequenceWrapper, newIndex int, err error)

+ func (essw *ExecutionSegmentSequenceWrapper) GetStripedOffsets(segmentIndex int) (int64, []int64, int64)

+ func (essw *ExecutionSegmentSequenceWrapper) GetTuple(segmentIndex int) *ExecutionTuple

+ func (essw *ExecutionSegmentSequenceWrapper) LCD() int64

+ func (essw *ExecutionSegmentSequenceWrapper) ScaleInt64(segmentIndex int, value int64) int64

+ type ExecutionState struct

+ ExecutionTuple *ExecutionTuple

+ Options Options

+ func NewExecutionState(options Options, et *ExecutionTuple, maxPlannedVUs, maxPossibleVUs uint64) *ExecutionState

+ func (es *ExecutionState) AddFullIterations(count uint64) uint64

+ func (es *ExecutionState) AddInitializedVU(vu InitializedVU)

+ func (es *ExecutionState) AddInterruptedIterations(count uint64) uint64

+ func (es *ExecutionState) GetCurrentExecutionStatus() ExecutionStatus

+ func (es *ExecutionState) GetCurrentTestRunDuration() time.Duration

+ func (es *ExecutionState) GetCurrentlyActiveVUsCount() int64

+ func (es *ExecutionState) GetFullIterationCount() uint64

+ func (es *ExecutionState) GetInitializedVUsCount() int64

+ func (es *ExecutionState) GetPartialIterationCount() uint64

+ func (es *ExecutionState) GetPlannedVU(logger *logrus.Entry, modifyActiveVUCount bool) (InitializedVU, error)

+ func (es *ExecutionState) GetUniqueVUIdentifier() uint64

+ func (es *ExecutionState) GetUnplannedVU(ctx context.Context, logger *logrus.Entry) (InitializedVU, error)

+ func (es *ExecutionState) HasEnded() bool

+ func (es *ExecutionState) HasStarted() bool

+ func (es *ExecutionState) InitializeNewVU(ctx context.Context, logger *logrus.Entry) (InitializedVU, error)

+ func (es *ExecutionState) IsPaused() bool

+ func (es *ExecutionState) MarkEnded()

+ func (es *ExecutionState) MarkStarted()

+ func (es *ExecutionState) ModCurrentlyActiveVUsCount(mod int64) int64

+ func (es *ExecutionState) ModInitializedVUsCount(mod int64) int64

+ func (es *ExecutionState) Pause() error

+ func (es *ExecutionState) Resume() error

+ func (es *ExecutionState) ResumeNotify() <-chan struct{}

+ func (es *ExecutionState) ReturnVU(vu InitializedVU, wasActive bool)

+ func (es *ExecutionState) SetExecutionStatus(newStatus ExecutionStatus) (oldStatus ExecutionStatus)

+ func (es *ExecutionState) SetInitVUFunc(initVUFunc InitVUFunc)

+ type ExecutionStatus uint32

+ const ExecutionStatusCreated

+ const ExecutionStatusEnded

+ const ExecutionStatusInitDone

+ const ExecutionStatusInitExecutors

+ const ExecutionStatusInitVUs

+ const ExecutionStatusPausedBeforeRun

+ const ExecutionStatusRunning

+ const ExecutionStatusSetup

+ const ExecutionStatusStarted

+ const ExecutionStatusTeardown

+ func ExecutionStatusString(s string) (ExecutionStatus, error)

+ func ExecutionStatusValues() []ExecutionStatus

+ func (i ExecutionStatus) IsAExecutionStatus() bool

+ func (i ExecutionStatus) String() string

+ type ExecutionStep struct

+ MaxUnplannedVUs uint64

+ PlannedVUs uint64

+ TimeOffset time.Duration

+ type ExecutionTuple struct

+ Segment *ExecutionSegment

+ SegmentIndex int

+ Sequence *ExecutionSegmentSequenceWrapper

+ func NewExecutionTuple(segment *ExecutionSegment, sequence *ExecutionSegmentSequence) (*ExecutionTuple, error)

+ func (et *ExecutionTuple) GetNewExecutionTupleFromValue(value int64) (*ExecutionTuple, error)

+ func (et *ExecutionTuple) GetStripedOffsets() (int64, []int64, int64)

+ func (et *ExecutionTuple) ScaleInt64(value int64) int64

+ func (et *ExecutionTuple) String() string

type Executor

+ GetConfig func() ExecutorConfig

+ GetProgress func() *pb.ProgressBar

+ Init func(ctx context.Context) error

+ type ExecutorConfig interface

+ GetDescription func(*ExecutionTuple) string

+ GetEnv func() map[string]string

+ GetExec func() string

+ GetExecutionRequirements func(*ExecutionTuple) []ExecutionStep

+ GetGracefulStop func() time.Duration

+ GetName func() string

+ GetStartTime func() time.Duration

+ GetTags func() map[string]string

+ GetType func() string

+ HasWork func(*ExecutionTuple) bool

+ IsDistributable func() bool

+ NewExecutor func(*ExecutionState, *logrus.Entry) (Executor, error)

+ Validate func() []error

+ func GetParsedExecutorConfig(name, configType string, rawJSON []byte) (result ExecutorConfig, err error)

+ type ExecutorConfigConstructor func(name string, rawJSON []byte) (ExecutorConfig, error)

+ type InitVUFunc func(context.Context, *logrus.Entry) (InitializedVU, error)

+ type InitializedVU interface

+ Activate func(*VUActivationParams) ActiveVU

+ GetID func() int64

+ type LiveUpdatableExecutor interface

+ UpdateConfig func(ctx context.Context, newConfig interface{}) error

type Options

+ ExecutionSegment *ExecutionSegment

+ ExecutionSegmentSequence *ExecutionSegmentSequence

+ NoSetup null.Bool

+ NoTeardown null.Bool

+ Scenarios ScenarioConfigs

+ type PausableExecutor interface

+ SetPaused func(bool) error

type Runner

+ IsExecutable func(string) bool

+ type ScenarioConfigs map[string]ExecutorConfig

+ func (scs *ScenarioConfigs) UnmarshalJSON(data []byte) error

+ func (scs ScenarioConfigs) GetFullExecutionRequirements(et *ExecutionTuple) []ExecutionStep

+ func (scs ScenarioConfigs) GetSortedConfigs() []ExecutorConfig

+ func (scs ScenarioConfigs) Validate() (errors []error)

type State

+ Tags map[string]string

+ func (s *State) CloneTags() map[string]string

+ type VUActivationParams struct

+ DeactivateCallback func(InitializedVU)

+ Env map[string]string

+ Exec string

+ RunContext context.Context

+ Scenario string

+ Tags map[string]string

Dec 16, 2019

Changes in this version

+ var DefaultSummaryTrendStats = []string

+ func ValidateCompatibilityMode(val string) (cm compiler.CompatibilityMode, err error)

type Archive

+ CompatibilityMode string

+ type MultiSlotLimiter struct

+ func NewMultiSlotLimiter(slots int) *MultiSlotLimiter

+ func (l *MultiSlotLimiter) Slot(s string) SlotLimiter

type Options

+ HTTPDebug null.String

type RuntimeOptions

+ CompatibilityMode null.String

+ type SlotLimiter chan struct

+ func NewSlotLimiter(slots int) SlotLimiter

+ func (sl SlotLimiter) Begin()

+ func (sl SlotLimiter) End()

type TimeoutError

+ func (t TimeoutError) Hint() string

+ func (t TimeoutError) Place() string

Jul 31, 2019

Changes in this version

+ const TLS13_CIPHER_SUITE_TLS_AES_128_GCM_SHA256

+ const TLS13_CIPHER_SUITE_TLS_AES_256_GCM_SHA384

+ const TLS13_CIPHER_SUITE_TLS_CHACHA20_POLY1305_SHA256

+ const TLSVersion13

type Archive

+ FilenameURL *url.URL

+ Filesystems map[string]afero.Fs

+ Goos string

+ K6Version string

+ PwdURL *url.URL

+ type IPNet net.IPNet

+ func ParseCIDR(s string) (*IPNet, error)

+ func (ipnet *IPNet) String() string

+ func (ipnet *IPNet) UnmarshalText(b []byte) error

Mar 20, 2019

Changes in this version

+ const DefaultSchedulerName

+ func WithState(ctx context.Context, state *State) context.Context

+ type DialContexter interface

+ DialContext func(ctx context.Context, network, addr string) (net.Conn, error)

type Options

+ ConsoleOutput null.String

+ Execution scheduler.ConfigMap

+ func (o Options) ForEachSpecified(structTag string, callback func(key string, value interface{}))

+ func (o Options) Validate() []error

+ type State struct

+ BPool *bpool.BufferPool

+ CookieJar *cookiejar.Jar

+ Dialer DialContexter

+ Group *Group

+ Iteration int64

+ Logger *log.Logger

+ Options Options

+ RPSLimit *rate.Limiter

+ Samples chan<- stats.SampleContainer

+ TLSConfig *tls.Config

+ Transport http.RoundTripper

+ Vu int64

+ func GetState(ctx context.Context) *State

type TagSet

+ func (t *TagSet) UnmarshalText(data []byte) error

+ type TimeoutError string

+ func NewTimeoutError(place string) TimeoutError

+ func (t TimeoutError) Error() string

+ func (t TimeoutError) String() string

Nov 22, 2018

Changes in this version

type Archive

+ FS afero.Fs

type Options

+ DiscardResponseBodies null.Bool

+ MinIterationDuration types.NullDuration

+ NoCookiesReset null.Bool

Jul 23, 2018

Changes in this version

type Options

+ func (o Options) ForEachValid(structTag string, callback func(key string, value interface{}))

Jul 6, 2018

Changes in this version

type MiniRunnerVU

+ Out chan<- stats.SampleContainer

type Options

+ MetricSamplesBufferSize null.Int

+ NoVUConnectionReuse null.Bool

+ func (o Options) GetPrettyJSON(prefix, indent string) ([]byte, error)

+ type RunStatus int

+ const RunStatusCreated

+ const RunStatusInitializing

+ const RunStatusQueued

+ const RunStatusRunning

+ const RunStatusTimedOut

+ const RunStatusValidated

Jun 4, 2018

Changes in this version

+ const RunStatusAbortedScriptError

+ const RunStatusAbortedSystem

+ const RunStatusAbortedThreshold

+ const RunStatusAbortedUser

+ const RunStatusFinished

type Collector

+ SetRunStatus func(status int)

May 23, 2018

Changes in this version

+ func NormalizeAndAnonymizePath(path string) string

type MiniRunner

+ func (r *MiniRunner) SetSetupData(data interface{})

+ func (r MiniRunner) GetSetupData() interface{}

type Options

+ RunTags *stats.SampleTags

+ SetupTimeout types.NullDuration

+ SummaryTimeUnit null.String

+ TeardownTimeout types.NullDuration

type Runner

+ GetSetupData func() interface{}

+ SetSetupData func(interface{})

Mar 22, 2018

Changes in this version

+ var DefaultSystemTagList = []string

type Archive

+ Env map[string]string

type Collector

+ GetRequiredSystemTags func() TagSet

type Executor

+ SetRunSetup func(r bool)

+ SetRunTeardown func(r bool)

+ type MiniRunner struct

+ Fn func(ctx context.Context) ([]stats.Sample, error)

+ Group *Group

+ Options Options

+ SetupFn func(ctx context.Context) error

+ TeardownFn func(ctx context.Context) error

+ func (r *MiniRunner) SetOptions(opts Options)

+ func (r MiniRunner) GetDefaultGroup() *Group

+ func (r MiniRunner) GetOptions() Options

+ func (r MiniRunner) MakeArchive() *Archive

+ func (r MiniRunner) NewVU() (VU, error)

+ func (r MiniRunner) Setup(ctx context.Context) error

+ func (r MiniRunner) Teardown(ctx context.Context) error

+ func (r MiniRunner) VU() *MiniRunnerVU

+ type MiniRunnerVU struct

+ ID int64

+ R MiniRunner

+ func (vu *MiniRunnerVU) Reconfigure(id int64) error

+ func (vu MiniRunnerVU) RunOnce(ctx context.Context) ([]stats.Sample, error)

type Options

+ Hosts map[string]net.IP

+ HttpDebug null.String

+ SystemTags TagSet

type Runner

+ Setup func(ctx context.Context) error

+ Teardown func(ctx context.Context) error

+ type RuntimeOptions struct

+ Env map[string]string

+ IncludeSystemEnvVars null.Bool

+ func (o RuntimeOptions) Apply(opts RuntimeOptions) RuntimeOptions

+ type TagSet map[string]bool

+ func GetTagSet(tags ...string) TagSet

+ func (t *TagSet) UnmarshalJSON(data []byte) error

+ func (t TagSet) MarshalJSON() ([]byte, error)

Jan 23, 2018

Changes in this version

+ const GroupSeparator

+ var SupportedTLSVersionsToString = map[TLSVersion]string

type Options

+ BatchPerHost null.Int

+ RPS null.Int

+ SummaryTrendStats []string

type TLSVersion

+ func (v TLSVersion) MarshalJSON() ([]byte, error)

+ type TLSVersions TLSVersionsFields

+ func (v *TLSVersions) UnmarshalJSON(data []byte) error

+ type TLSVersionsFields struct

+ Max TLSVersion

+ Min TLSVersion

Dec 7, 2017

Changes in this version

type NullDuration

+ func SumStages(stages []Stage) (d NullDuration)

type Options

+ Batch null.Int

+ BlacklistIPs []*net.IPNet

Nov 23, 2017

Changes in this version

type Runner

+ SetOptions func(opts Options)

type RunnerFunc

+ func (fn RunnerFunc) SetOptions(opts Options)

Nov 20, 2017

Changes in this version

+ var SupportedTLSCipherSuitesToString = map[uint16]string

type Collector

+ Link func() string

type Duration

+ func (d *Duration) UnmarshalText(data []byte) error

type Executor

+ GetStages func() []Stage

+ SetStages func(s []Stage)

type NullDuration

+ func (d *NullDuration) UnmarshalText(data []byte) error

type Stage

+ func (s *Stage) UnmarshalText(b []byte) error

+ func (s Stage) MarshalJSON() ([]byte, error)

+ type StageFields struct

+ Duration NullDuration

+ Target null.Int

Aug 31, 2017

Changes in this version

type Options

+ TLSAuth []*TLSAuth

+ type TLSAuth struct

+ func (c *TLSAuth) Certificate() (*tls.Certificate, error)

+ func (c *TLSAuth) UnmarshalJSON(data []byte) error

+ type TLSAuthFields struct

+ Cert string

+ Domains []string

+ Key string

Jul 7, 2017

Changes in this version

+ var SupportedTLSCipherSuites = map[string]uint16

+ var SupportedTLSVersions = map[string]int

+ func Max(a, b int64) int64

+ func Min(a, b int64) int64

+ type AtomicBool struct

+ func (a *AtomicBool) Get() bool

+ func (a *AtomicBool) Set(v bool)

type Collector

+ IsReady func() bool

+ type Executor interface

+ GetEndIterations func() null.Int

+ GetEndTime func() NullDuration

+ GetIterations func() int64

+ GetLogger func() *log.Logger

+ GetRunner func() Runner

+ GetTime func() time.Duration

+ GetVUs func() int64

+ GetVUsMax func() int64

+ IsPaused func() bool

+ IsRunning func() bool

+ Run func(ctx context.Context, out chan<- []stats.Sample) error

+ SetEndIterations func(i null.Int)

+ SetEndTime func(t NullDuration)

+ SetLogger func(l *log.Logger)

+ SetPaused func(paused bool)

+ SetVUs func(vus int64) error

+ SetVUsMax func(max int64) error

type Options

+ TLSCipherSuites *TLSCipherSuites

+ TLSVersion *TLSVersion

+ type TLSCipherSuites []uint16

+ func (s *TLSCipherSuites) UnmarshalJSON(data []byte) error

+ type TLSVersion struct

+ Max int

+ Min int

+ func (v *TLSVersion) UnmarshalJSON(data []byte) error

Jun 16, 2017

Changes in this version

+ type AuthenticatedCollector interface

+ Login func(conf interface{}, in io.Reader, out io.Writer) (interface{}, error)

type Collector

+ MakeConfig func() interface{}

type Duration

+ func (d Duration) MarshalJSON() ([]byte, error)

+ func (d Duration) String() string

+ type NullDuration struct

+ Valid bool

+ func NullDurationFrom(d time.Duration) NullDuration

+ func (d *NullDuration) UnmarshalJSON(data []byte) error

+ func (d NullDuration) MarshalJSON() ([]byte, error)

May 19, 2017

Changes in this version

+ func AnonymizePath(path string) string

+ type Archive struct

+ Data []byte

+ Filename string

+ Files map[string][]byte

+ Options Options

+ Pwd string

+ Scripts map[string][]byte

+ Type string

+ func ReadArchive(in io.Reader) (*Archive, error)

+ func (arc *Archive) Write(out io.Writer) error

type Options

+ Throw null.Bool

+ UserAgent null.String

type Runner

+ MakeArchive func() *Archive

type RunnerFunc

+ func (fn RunnerFunc) MakeArchive() *Archive

May 10, 2017

Changes in this version

type Options

+ NoConnectionReuse null.Bool

May 8, 2017

Changes in this version

type Options

+ External map[string]interface{}

Apr 12, 2017

Changes in this version

type Collector

+ Init func()

type Trail

+ EndTime time.Time

Feb 27, 2017

Changes in this version

type RunnerFunc

+ func (fn RunnerFunc) VU() *RunnerFuncVU

+ type RunnerFuncVU struct

+ Fn RunnerFunc

+ ID int64

+ func (fn *RunnerFuncVU) Reconfigure(id int64) error

+ func (fn RunnerFuncVU) RunOnce(ctx context.Context) ([]stats.Sample, error)

Feb 16, 2017

Changes in this version

+ type Duration time.Duration

+ func (d *Duration) UnmarshalJSON(data []byte) error

type Stage

+ func (s *Stage) UnmarshalJSON(data []byte) error

Feb 13, 2017

Changes in this version

+ type SourceData struct

+ Data []byte

+ Filename string

Feb 6, 2017

Changes in this version

+ const BackoffAmount

+ const BackoffMax

Feb 2, 2017

Changes in this version

+ type Collector interface

+ Collect func(samples []stats.Sample)

+ Run func(ctx context.Context)

Feb 2, 2017

Changes in this version

+ func SplitKV(s string) (key, value string)

type Options

+ InsecureSkipTLSVerify null.Bool

+ NoUsageReport null.Bool

type Trail

+ StartTime time.Time

+ func (tr Trail) Samples(tags map[string]string) []stats.Sample

Jan 27, 2017

Changes in this version

+ var ErrNameContainsGroupSeparator = errors.Errorf("group and check names may not contain '%s'", groupSeparator)

+ var MetricChecks = stats.New("checks", stats.Rate)

type Check

+ Path string

type Group

+ Path string

Jan 26, 2017

Changes in this version

type Options

+ Iterations null.Int

Jan 16, 2017

Changes in this version

+ const CollectRate

+ const MetricsRate

+ const ThresholdsRate

+ var MetricIterations = stats.New("iterations", stats.Gauge)

+ var MetricTaints = stats.New("taints", stats.Gauge)

+ func Clampf(val, min, max float64) float64

type Engine

+ Logger *log.Logger

+ MetricsLock sync.Mutex

+ Options Options

+ func (e *Engine) AtTime() time.Duration

+ func (e *Engine) GetVUs() int64

+ func (e *Engine) GetVUsMax() int64

+ func (e *Engine) IsPaused() bool

+ func (e *Engine) IsTainted() bool

+ func (e *Engine) SetPaused(v bool)

+ func (e *Engine) SetVUsMax(v int64) error

type Options

+ Stages []Stage

type Runner

+ GetDefaultGroup func() *Group

+ type RunnerFunc func(ctx context.Context) ([]stats.Sample, error)

+ func (fn RunnerFunc) ApplyOptions(opts Options)

+ func (fn RunnerFunc) GetDefaultGroup() *Group

+ func (fn RunnerFunc) GetOptions() Options

+ func (fn RunnerFunc) NewVU() (VU, error)

+ func (fn RunnerFunc) Reconfigure(id int64) error

+ func (fn RunnerFunc) RunOnce(ctx context.Context) ([]stats.Sample, error)

type Stage

+ Target null.Int

type Threshold

+ func NewThreshold(src string, vm *otto.Otto) (*Threshold, error)

+ func (t *Threshold) Run() (bool, error)

+ func (t Threshold) RunNoTaint() (bool, error)

+ type Thresholds struct

+ Thresholds []*Threshold

+ VM *otto.Otto

+ func NewThresholds(sources []string) (Thresholds, error)

+ func (ts *Thresholds) Run(sink stats.Sink) (bool, error)

+ func (ts *Thresholds) RunAll() (bool, error)

+ func (ts *Thresholds) UnmarshalJSON(data []byte) error

+ func (ts *Thresholds) UpdateVM(sink stats.Sink) error

+ func (ts Thresholds) MarshalJSON() ([]byte, error)

Dec 14, 2016

Changes in this version

+ const ShutdownTimeout

+ const ThresholdTickRate

+ const TickRate

+ var ErrMaxTooLow = errors.New("Can't lower max below current VU count")

+ var ErrTooManyVUs = errors.New("More VUs than the maximum requested")

+ var ErrVUWantsTaint = errors.New("silent taint")

+ var MetricErrors = &stats.Metric

+ var MetricRuns = &stats.Metric

+ var MetricVUs = &stats.Metric

+ var MetricVUsMax = &stats.Metric

+ func Lerp(x, y int64, t float64) int64

+ type Check struct

+ Fails int64

+ Group *Group

+ ID int64

+ Name string

+ Passes int64

+ func NewCheck(name string, group *Group, idCounter *int64) *Check

+ func (c Check) GetID() string

+ func (c Check) GetReferencedIDs() []jsonapi.ReferenceID

+ func (c Check) GetReferencedStructs() []jsonapi.MarshalIdentifier

+ func (c Check) GetReferences() []jsonapi.Reference

+ type CookieJar struct

+ func NewCookieJar() *CookieJar

+ func (j *CookieJar) Clear()

+ func (j *CookieJar) Cookies(u *url.URL) []*http.Cookie

+ func (j *CookieJar) SetCookies(u *url.URL, cookies []*http.Cookie)

+ type Engine struct

+ Collector stats.Collector

+ Metrics map[*stats.Metric]stats.Sink

+ Pause sync.WaitGroup

+ Runner Runner

+ Stages []Stage

+ Status Status

+ Thresholds map[string][]*Threshold

+ func NewEngine(r Runner) (*Engine, error)

+ func (e *Engine) Apply(opts Options) error

+ func (e *Engine) IsRunning() bool

+ func (e *Engine) Run(ctx context.Context) error

+ func (e *Engine) SetMaxVUs(v int64) error

+ func (e *Engine) SetRunning(running bool)

+ func (e *Engine) SetVUs(v int64) error

+ func (e *Engine) TotalTime() (total time.Duration, finite bool)

+ type Group struct

+ Checks map[string]*Check

+ Groups map[string]*Group

+ ID int64

+ Name string

+ Parent *Group

+ func NewGroup(name string, parent *Group, idCounter *int64) *Group

+ func (g *Group) Check(name string, idCounter *int64) (*Check, bool)

+ func (g *Group) Group(name string, idCounter *int64) (*Group, bool)

+ func (g Group) GetID() string

+ func (g Group) GetReferencedIDs() []jsonapi.ReferenceID

+ func (g Group) GetReferencedStructs() []jsonapi.MarshalIdentifier

+ func (g Group) GetReferences() []jsonapi.Reference

+ type Info struct

+ Version string

+ func (i Info) GetID() string

+ func (i Info) GetName() string

+ type Options struct

+ AbortOnTaint null.Bool

+ Acceptance null.Float

+ Duration null.String

+ Linger null.Bool

+ MaxRedirects null.Int

+ Paused null.Bool

+ Thresholds map[string][]*Threshold

+ VUs null.Int

+ VUsMax null.Int

+ func (o Options) Apply(opts Options) Options

+ func (o Options) SetAllValid(valid bool) Options

+ type Runner interface

+ ApplyOptions func(opts Options)

+ GetChecks func() []*Check

+ GetGroups func() []*Group

+ GetOptions func() Options

+ NewVU func() (VU, error)

+ type Stage struct

+ Duration null.Int

+ EndVUs null.Int

+ ID int64

+ Order null.Int

+ StartVUs null.Int

+ func StageAt(stages []Stage, offset time.Duration) (s Stage, stageLeft time.Duration, ok bool)

+ func (s *Stage) SetID(v string) error

+ func (s Stage) GetID() string

+ func (s Stage) GetName() string

+ type Status struct

+ AbortOnTaint null.Bool

+ Acceptance null.Float

+ AtTime null.Int

+ Linger null.Bool

+ Running null.Bool

+ Runs int64

+ Tainted null.Bool

+ Taints int64

+ VUs null.Int

+ VUsMax null.Int

+ func (s Status) GetID() string

+ func (s Status) GetName() string

+ func (s Status) SetID(id string) error

+ type Threshold struct

+ Failed bool

+ Script *otto.Script

+ Source string

+ func (t *Threshold) UnmarshalJSON(data []byte) error

+ func (t Threshold) MarshalJSON() ([]byte, error)

+ func (t Threshold) String() string

+ type Tracer struct

+ func (t *Tracer) ConnectDone(network, addr string, err error)

+ func (t *Tracer) ConnectStart(network, addr string)

+ func (t *Tracer) DNSDone(info httptrace.DNSDoneInfo)

+ func (t *Tracer) DNSStart(info httptrace.DNSStartInfo)

+ func (t *Tracer) Done() Trail

+ func (t *Tracer) GetConn(hostPort string)

+ func (t *Tracer) GotConn(info httptrace.GotConnInfo)

+ func (t *Tracer) GotFirstResponseByte()

+ func (t *Tracer) Trace() *httptrace.ClientTrace

+ func (t *Tracer) WroteRequest(info httptrace.WroteRequestInfo)

+ type Trail struct

+ Blocked time.Duration

+ ConnRemoteAddr net.Addr

+ ConnReused bool

+ Connecting time.Duration

+ Duration time.Duration

+ LookingUp time.Duration

+ Receiving time.Duration

+ Sending time.Duration

+ Waiting time.Duration

+ type VU interface

+ Reconfigure func(id int64) error

+ RunOnce func(ctx context.Context) ([]stats.Sample, error)