Versions in this module Expand all Collapse all v1 v1.0.0 Sep 7, 2016 Changes in this version + type ConcurrencyLimiter struct + func NewConcurrencyLimiter(max int) *ConcurrencyLimiter + func (c *ConcurrencyLimiter) Decrement() + func (c *ConcurrencyLimiter) Increment() + func (c *ConcurrencyLimiter) NewMax(i int) + type Directive struct + Property string + Tracer *Tracer + Value string + func NewDirective(property string, value string, tracer *Tracer) Directive + type Package struct + Body []byte + StatementID string + T Type + Tracer *Tracer + func NewPackage(t Type, body []byte, statementID string, tracer *Tracer) Package + type Response struct + Point *influx.Point + Tracer *Tracer + func NewResponse(pt *influx.Point, tr *Tracer) Response + func (resp Response) AddTags(newTags map[string]string) *influx.Point + type StressTest struct + BatchSize int + Precision string + ResultsChan chan Response + ResultsClient influx.Client + StartDate string + TestDB string + TestID string + func NewStressTest() *StressTest + func NewTestStressTest() (*StressTest, chan Package, chan Directive) + func (st *StressTest) GetPoint(name, precision string) models.Point + func (st *StressTest) GetStatementResults(sID, t string) (res []influx.Result) + func (st *StressTest) NewResultsPointBatch() influx.BatchPoints + func (st *StressTest) SendDirective(d Directive) + func (st *StressTest) SendPackage(p Package) + func (st *StressTest) SetCommune(name string) chan<- string + type Tracer struct + Tags map[string]string + func NewTracer(tags map[string]string) *Tracer + type Type int + const Query + const Write v1.0.0-rc2 Aug 29, 2016 v1.0.0-rc1 Aug 22, 2016 v1.0.0-beta3 Jul 18, 2016
Go to main page