Versions in this module Expand all Collapse all v1 v1.0.0 Aug 2, 2020 Changes in this version + const AllQueriesLabel + const Dashboard + var Benchmarker = &QueryBenchmarker + type BulkQuery interface + CleanUp func() + GetProcessor func() Processor + GetScanner func() Scanner + Init func() + Prepare func() + UpdateReport func(params *report.QueryReportParams, reportTags [][2]string, ...) ([][2]string, []report.ExtraVal) + Validate func() + type HistoryItem struct + Item int + Value float64 + type Processor interface + PrepareProcess func(i int) + RunProcess func(i int, qorkersGroup *sync.WaitGroup, statPool sync.Pool, statChan chan *Stat) + type QueryBenchmarker struct + func (q *QueryBenchmarker) Init() + func (q *QueryBenchmarker) RunBenchmark(bulkQuery BulkQuery) + func (q *QueryBenchmarker) Validate() + func (q QueryBenchmarker) BatchSize() int + func (q QueryBenchmarker) BurnIn() uint64 + func (q QueryBenchmarker) Debug() int + func (q QueryBenchmarker) GradualWorkersIncrease() bool + func (q QueryBenchmarker) Limit() int64 + func (q QueryBenchmarker) PrettyPrintResponses() bool + func (q QueryBenchmarker) WaitInterval() time.Duration + type Scanner interface + IsScanFinished func() bool + RunScan func(r io.Reader, closeChan chan int) + type SimpleRegression struct + func (sr *SimpleRegression) Intercept() float64 + func (sr *SimpleRegression) Slope() float64 + func (sr *SimpleRegression) Update(x, y float64) + type Stat struct + IsActual bool + Label []byte + Value float64 + func (s *Stat) Init(label []byte, value float64) + func (s *Stat) InitWithActual(label []byte, value float64, isActual bool) + type StatGroup struct + Count int64 + Max float64 + Mean float64 + Min float64 + Sum float64 + func (s *StatGroup) Push(n float64) + func (s *StatGroup) String() string + type StatsMap map[string]*StatGroup + type TimedStatGroup struct + func NewTimedStatGroup(maxDuration time.Duration, maxTrendSamples int) *TimedStatGroup + func (m *TimedStatGroup) Avg() float64 + func (m *TimedStatGroup) FindHistoryItemBelow(val float64) *HistoryItem + func (m *TimedStatGroup) Median() float64 + func (m *TimedStatGroup) Push(timestamp time.Time, value float64) + func (m *TimedStatGroup) UpdateAvg(now time.Time, workers int) (float64, float64) + type TrendStat struct + func NewTrendStat(size int, skipFirst bool) *TrendStat + func (ls *TrendStat) Add(y float64)
Go to main page