Documentation
¶
Index ¶
- type ConcurrencyRunner
- func (r *ConcurrencyRunner) After(test int, options interface{})
- func (r *ConcurrencyRunner) Before(workers tester.Workers, opts interface{}) error
- func (r *ConcurrencyRunner) Recorder() chan interface{}
- func (r *ConcurrencyRunner) Recorders() []bender.Recorder
- func (r *ConcurrencyRunner) Requests() chan interface{}
- func (r *ConcurrencyRunner) Tester() tester.Tester
- func (r *ConcurrencyRunner) WorkerSemaphore() *bender.WorkerSemaphore
- type Params
- type RequestGenerator
- type ThroughputRunner
- func (r *ThroughputRunner) After(test int, options interface{})
- func (r *ThroughputRunner) Before(qps tester.QPS, opts interface{}) error
- func (r *ThroughputRunner) Intervals() bender.IntervalGenerator
- func (r *ThroughputRunner) Recorder() chan interface{}
- func (r *ThroughputRunner) Recorders() []bender.Recorder
- func (r *ThroughputRunner) Requests() chan interface{}
- func (r *ThroughputRunner) Tester() tester.Tester
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConcurrencyRunner ¶
type ConcurrencyRunner struct {
// contains filtered or unexported fields
}
ConcurrencyRunner is a test runner for load test concurrency commands.
func NewConcurrencyRunner ¶
func NewConcurrencyRunner(params *Params) *ConcurrencyRunner
NewConcurrencyRunner returns new ConcurrencyRunner.
func (*ConcurrencyRunner) After ¶
func (r *ConcurrencyRunner) After(test int, options interface{})
After cleans up after the test.
func (*ConcurrencyRunner) Before ¶
func (r *ConcurrencyRunner) Before(workers tester.Workers, opts interface{}) error
Before prepares requests, recorders and interval generator.
func (*ConcurrencyRunner) Recorder ¶
func (r *ConcurrencyRunner) Recorder() chan interface{}
Recorder returns the recorder.
func (*ConcurrencyRunner) Requests ¶
func (r *ConcurrencyRunner) Requests() chan interface{}
Requests returns the requests channel.
func (*ConcurrencyRunner) WorkerSemaphore ¶
func (r *ConcurrencyRunner) WorkerSemaphore() *bender.WorkerSemaphore
WorkerSemaphore returns a worker semaphore for concurrency test.
type Params ¶
type Params struct {
Tester tester.Tester
RequestGenerator RequestGenerator
}
Params represents test parameters for the runner.
type RequestGenerator ¶
type RequestGenerator func(i int) interface{}
RequestGenerator is used to generate requests.
type ThroughputRunner ¶
type ThroughputRunner struct {
// contains filtered or unexported fields
}
ThroughputRunner is a test runner for load test throughput commands.
func NewThroughputRunner ¶
func NewThroughputRunner(params *Params) *ThroughputRunner
NewThroughputRunner returns new ThroughputRunner.
func (*ThroughputRunner) After ¶
func (r *ThroughputRunner) After(test int, options interface{})
After cleans up after the test.
func (*ThroughputRunner) Before ¶
func (r *ThroughputRunner) Before(qps tester.QPS, opts interface{}) error
Before prepares requests, recorders and interval generator.
func (*ThroughputRunner) Intervals ¶
func (r *ThroughputRunner) Intervals() bender.IntervalGenerator
Intervals returns the interval generator.
func (*ThroughputRunner) Recorder ¶
func (r *ThroughputRunner) Recorder() chan interface{}
Recorder returns the recorder.
Source Files