Versions in this module Expand all Collapse all v0 v0.1.1 Nov 11, 2022 v0.1.0 Nov 11, 2022 Changes in this version + const BenchmarkTestResultVersion + var HTTPPool = sync.Pool + var TDenginePool = sync.Pool + var TimescaleDBPool = sync.Pool + type BenchmarkRunner struct + func NewBenchmarkRunner(config BenchmarkRunnerConfig) *BenchmarkRunner + func (b *BenchmarkRunner) DatabaseName() string + func (b *BenchmarkRunner) DebugLevel() int + func (b *BenchmarkRunner) DoPrintResponses() bool + func (b *BenchmarkRunner) GetBufferedReader() *bufio.Reader + func (b *BenchmarkRunner) Run(queryPool *sync.Pool, processorCreateFn ProcessorCreate) + func (b *BenchmarkRunner) SetLimit(limit uint64) + type BenchmarkRunnerConfig struct + BurnIn uint64 + DBName string + Debug int + FileName string + HDRLatenciesFile string + Limit uint64 + LimitRPS uint64 + MemProfile string + PrewarmQueries bool + PrintInterval uint64 + PrintResponses bool + ResultsFile string + Workers uint + func (c BenchmarkRunnerConfig) AddToFlagSet(fs *pflag.FlagSet) + type HTTP struct + Body []byte + EndTimestamp int64 + HumanDescription []byte + HumanLabel []byte + Method []byte + Path []byte + RawQuery []byte + StartTimestamp int64 + func NewHTTP() *HTTP + func (q *HTTP) GetID() uint64 + func (q *HTTP) HumanDescriptionName() []byte + func (q *HTTP) HumanLabelName() []byte + func (q *HTTP) Release() + func (q *HTTP) SetID(n uint64) + func (q *HTTP) String() string + type LoaderTestResult struct + DurationMillis int64 + EndTime int64 + ResultFormatVersion string + RunnerConfig BenchmarkRunnerConfig + StartTime int64 + Totals map[string]interface{} + type Processor interface + Init func(workerNum int) + ProcessQuery func(q Query, isWarm bool) ([]*Stat, error) + type ProcessorCreate func() Processor + type Query interface + GetID func() uint64 + HumanDescriptionName func() []byte + HumanLabelName func() []byte + Release func() + SetID func(uint64) + type Stat struct + func GetPartialStat() *Stat + func GetStat() *Stat + func (s *Stat) Init(label []byte, value float64) *Stat + type TDengine struct + HumanDescription []byte + HumanLabel []byte + SqlQuery []byte + func NewTDengine() *TDengine + func (q *TDengine) GetID() uint64 + func (q *TDengine) HumanDescriptionName() []byte + func (q *TDengine) HumanLabelName() []byte + func (q *TDengine) Release() + func (q *TDengine) SetID(n uint64) + func (q *TDengine) String() string + type TimescaleDB struct + HumanDescription []byte + HumanLabel []byte + Hypertable []byte + SqlQuery []byte + func NewTimescaleDB() *TimescaleDB + func (q *TimescaleDB) GetID() uint64 + func (q *TimescaleDB) HumanDescriptionName() []byte + func (q *TimescaleDB) HumanLabelName() []byte + func (q *TimescaleDB) Release() + func (q *TimescaleDB) SetID(n uint64) + func (q *TimescaleDB) String() string