lib

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)