Versions in this module Expand all Collapse all v1 v1.0.3 Jun 9, 2023 Changes in this version + var DefaultRunnerOptions = RunnerOptions + type Aborter struct + StartChan chan bool + StopChan chan struct{} + func NewAborter() *Aborter + func (a *Aborter) Abort(wait bool) + func (a *Aborter) Reset() + func (a *Aborter) String() string + type AccessLogger interface + Info func() string + Report func(ctx context.Context, threadID ThreadID, iter int64, startTime time.Time, ...) + Start func(ctx context.Context, threadID ThreadID, iter int64, startTime time.Time) context.Context + func NewFileAccessLogger(filePath, format string) (AccessLogger, error) + func NewFileAccessLoggerByType(filePath string, accessType AccessLoggerType) (AccessLogger, error) + type AccessLoggerType int + const AccessInflux + const AccessJSON + func (t AccessLoggerType) String() string + type HasRunnerResult interface + Result func() *RunnerResults + type PeriodicRunner interface + Options func() *RunnerOptions + Run func() RunnerResults + func NewPeriodicRunner(params *RunnerOptions) PeriodicRunner + type Runnable interface + Run func(context.Context, ThreadID) (status bool, details string) + type RunnerOptions struct + AccessLogger AccessLogger + Duration time.Duration + Exactly int64 + ID string + Jitter bool + Labels string + NoCatchUp bool + NumThreads int + Offset time.Duration + Out io.Writer + Percentiles []float64 + QPS float64 + Resolution float64 + RunID int64 + RunType string + Runners []Runnable + Stop *Aborter + Uniform bool + func (r *RunnerOptions) Abort() + func (r *RunnerOptions) AddAccessLogger(filePath, format string) error + func (r *RunnerOptions) GenID() + func (r *RunnerOptions) MakeRunners(rr Runnable) + func (r *RunnerOptions) Normalize() + func (r *RunnerOptions) ReleaseRunners() + type RunnerResults struct + AccessLoggerInfo string + ActualDuration time.Duration + ActualQPS float64 + DurationHistogram *stats.HistogramData + ErrorsDurationHistogram *stats.HistogramData + Exactly int64 + ID string + Jitter bool + Labels string + NoCatchUp bool + NumThreads int + RequestedDuration string + RequestedQPS int + RunID int64 + RunType string + StartTime time.Time + Uniform bool + Version string + func (r *RunnerResults) Result() *RunnerResults + type ThreadID int