lib

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)