httpt

type Runner struct {
	Config *RunnerConfig
	// Used for initializing groups,
	// all groups are initialized then close PauseC,
	// mean terminate paused status.
	PauseC                chan struct{}
	CancelC               chan struct{}
	MetricC               chan<- *metric.Metric
	AllGroupsDone         <-chan struct{}
	MetricCollectorsDoneC <-chan struct{}
}

type RunnerConfig struct {
	// Duration to run,
	// 0 mean no limit.
	Duration time.Duration
	Groups   []*RunnerGroup
	Metric   RunnerMetric
}

type RunnerGroup struct {
	// If func return error then will auto call Param.Error().
	RunFunc runfunc.Func
	// Number of `RunFunc` run concurrently.
	Number int
	// 0 mean no limit.
	MaxRPS float64
	// Fixed iterations of `RunFunc` run.
	Iteration int
	// contains filtered or unexported fields
}

type RunnerMetric struct {
	// All are disabled by default, manually enable if required.
	EnableDefaultRequestMetrics map[metric.DefaultRequestMetric]bool
	MetricCollectors            []metric.Collector
}