benchmark_runner

package

Go to main page

Versions in this module

v0

v0.3.5

Mar 31, 2023

v0.3.4

Mar 31, 2023

v0.3.3

Mar 31, 2023

v0.3.2

Feb 7, 2023

v0.3.1

Sep 30, 2022

Changes in this version

+ const Inf

type BenchmarkRunner

+ func (b *BenchmarkRunner) GetPerSecondEncodedHistogramsMap() map[uint64]string

type CmdStat

+ func (c *CmdStat) SetStartTs(startTs uint64)

+ func (c *CmdStat) StartTs() uint64

type TestResult

+ MaxRps uint64

+ PerSecondEncodedHistograms map[uint64]string

v0.3.0

Sep 15, 2020

Changes in this version

+ const CurrentResultFormatVersion

+ const SingleQueue

+ const WorkerPerQueue

+ type Batch interface

+ Append func(*DocHolder)

+ Len func() int

+ type BatchFactory interface

+ New func() Batch

+ type Benchmark interface

+ GetBatchFactory func() BatchFactory

+ GetCmdDecoder func(br *bufio.Reader) DocDecoder

+ GetCommandIndexer func(maxPartitions uint) DocIndexer

+ GetConfigurationParametersMap func() map[string]interface{}

+ GetProcessor func() Processor

+ type BenchmarkRunner struct

+ JsonOutFile string

+ Metadata string

+ func GetBenchmarkRunner() *BenchmarkRunner

+ func GetBenchmarkRunnerWithBatchSize(batchSize uint) *BenchmarkRunner

+ func (b *BenchmarkRunner) GetMeasuredRatiosMap() map[string]interface{}

+ func (b *BenchmarkRunner) GetOverallQuantiles() map[string]interface{}

+ func (b *BenchmarkRunner) GetTimeSeriesMap() map[string]interface{}

+ func (b *BenchmarkRunner) GetTotalsMap() map[string]interface{}

+ func (l *BenchmarkRunner) GetBufferedReader() *bufio.Reader

+ func (l *BenchmarkRunner) GetOverallRatesMap() map[string]interface{}

+ func (l *BenchmarkRunner) RunBenchmark(b Benchmark, workQueues uint)

+ type ByTimestamp []DataPoint

+ func (a ByTimestamp) Len() int

+ func (a ByTimestamp) Less(i, j int) bool

+ func (a ByTimestamp) Swap(i, j int)

+ type CmdStat struct

+ func NewCmdStat(cmdGroup []byte, cmdQueryId []byte, latency uint64, error bool, timedOut bool, ...) *CmdStat

+ func (c *CmdStat) CmdQueryId() []byte

+ func (c *CmdStat) Label() []byte

+ func (c *CmdStat) Latency() uint64

+ func (c *CmdStat) Rx() uint64

+ func (c *CmdStat) SetLabel(label []byte)

+ func (c *CmdStat) SetLatency(latency uint64)

+ func (c *CmdStat) SetRx(rx uint64)

+ func (c *CmdStat) SetTx(tx uint64)

+ func (c *CmdStat) Tx() uint64

+ type ConstantIndexer struct

+ func (i *ConstantIndexer) GetIndex(_ *DocHolder) int

+ type DataPoint struct

+ MultiValues map[string]float64

+ Timestamp int64

+ func NewDataPoint(timestamp int64) *DataPoint

+ func (p DataPoint) AddValue(s string, value float64)

+ type DocDecoder interface

+ Decode func(*bufio.Reader) *DocHolder

+ type DocHolder struct

+ Data interface{}

+ func NewDocument(data interface{}) *DocHolder

+ type DocIndexer interface

+ GetIndex func(uint64, *DocHolder) int

+ type Processor interface

+ Init func(workerNum int, doLoad bool, totalWorkers int)

+ ProcessBatch func(b Batch, doLoad bool) Stat

+ type ProcessorCloser interface

+ Close func(doLoad bool)

+ type Stat struct

+ func NewStat() *Stat

+ func (s *Stat) AddCmdStatEntry(stat CmdStat)

+ func (s *Stat) AddEntry(cmdGroup []byte, cmdQueryId []byte, latencyUs uint64, error bool, ...) *Stat

+ func (s *Stat) CmdStats() []CmdStat

+ func (s *Stat) GetCmdsCount() uint64

+ func (s *Stat) Merge(stat Stat)

+ func (s *Stat) SetCmdStats(cmdStats []CmdStat)

+ type TestResult struct

+ DBSpecificConfigs map[string]interface{}

+ DurationMillis int64

+ EndTime int64

+ Limit uint64

+ MeasuredRatios map[string]interface{}

+ Metadata string

+ OverallQuantiles map[string]interface{}

+ OverallRates map[string]interface{}

+ ResultFormatVersion string

+ StartTime int64

+ TimeSeries map[string]interface{}

+ Totals map[string]interface{}

+ Workers uint

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL