runner

Documentation

Index

• type Stat
  • func NewStat(name string) *Stat
  • func (s *Stat) Add(dur time.Duration)
  • func (s Stat) Report()
  • func (s Stat) ReportComputer()
• type TestRun
  • func NewTestRun(metricsChan chan *schema.MetricData, queriesChan chan string, ...) *TestRun
  • func (t *TestRun) Init(ctx context.Context)
  • func (t *TestRun) PrintStats()
  • func (t *TestRun) Run()
  • func (t *TestRun) Wait()

Types

type Stat

type Stat struct {
	Name  string
	Count int
	Total time.Duration
	Max   time.Duration
	// contains filtered or unexported fields
}

func NewStat

func NewStat(name string) *Stat

func (*Stat) Add

func (s *Stat) Add(dur time.Duration)

func (Stat) Report

func (s Stat) Report()

func (Stat) ReportComputer

func (s Stat) ReportComputer()

ReportComputer reports the stat in a computer friendly form in microseconds.

type TestRun

type TestRun struct {
	// contains filtered or unexported fields
}

TestRun represents one test run, including all the structures used for the test

func NewTestRun

func NewTestRun(metricsChan chan *schema.MetricData, queriesChan chan string, addsPerSec, addThreads, initialIndexSize, queriesPerSec uint32, concQueries int) *TestRun

NewTestRun Instantiates a new test run

func (*TestRun) Init

func (t *TestRun) Init(ctx context.Context)

Init prepares to run

func (*TestRun) PrintStats

func (t *TestRun) PrintStats()

PrintStats writes all the statistics in human readable format into stdout

func (*TestRun) Run

func (t *TestRun) Run()

Run executes the run

func (*TestRun) Wait

func (t *TestRun) Wait()