Versions in this module Expand all Collapse all v1 v1.0.0 Aug 2, 2020 Changes in this version + const ValuesPerMeasurement + var Runner = &LoadRunner + func RegisterHandler(notifHandler NotifyHandler) + type BatchProcessor interface + AfterRunProcess func(i int) + EmptyBatchChanel func() + PrepareProcess func(i int) + RunProcess func(i int, waitGroup *sync.WaitGroup, telemetryPoints chan *report.Point, ...) error + type BulkLoad interface + CleanUp func() + CreateDb func() + GetBatchProcessor func() BatchProcessor + GetScanner func() Scanner + Init func() + PrepareWorkers func() + SyncEnd func() + UpdateReport func(params *report.LoadReportParams) (reportTags [][2]string, extraVals []report.ExtraVal) + Validate func() + type HistoryItem struct + type LoadRunner struct + BatchSize int + DbName string + DoAbortOnExist bool + DoDBCreate bool + DoLoad bool + ItemLimit int64 + StatChan chan *Stat + StatPool sync.Pool + TimeLimit time.Duration + Workers int + func (r *LoadRunner) HasEndedPrematurely() bool + func (r *LoadRunner) Init(defaultBatchSize int) + func (r *LoadRunner) Run(load BulkLoad) int + func (r *LoadRunner) SetPrematureEnd(reason string) + func (r *LoadRunner) Validate() + type NotifyHandler func(arg int) (int, error) + type NotifyReceiver struct + func (t *NotifyReceiver) Notify(args *int, reply *int) error + type Scanner interface + GetReadStatistics func() (itemsRead, bytesRead, valuesRead int64) + IsScanFinished func() bool + RunScanner func(r io.Reader, syncChanDone 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 + Label []byte + Value float64 + func (s *Stat) Init(label []byte, value float64) + 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 TimedStatGroup struct + func NewTimedStatGroup(maxDuration time.Duration, maxTrendSamples int) *TimedStatGroup + func (m *TimedStatGroup) Avg() float64 + func (m *TimedStatGroup) Median() float64 + func (m *TimedStatGroup) Push(timestamp time.Time, value float64) + func (m *TimedStatGroup) Rate() 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)