Versions in this module Expand all Collapse all v1 v1.0.0-beta3 Jul 18, 2016 v1.0.0-beta1 Jun 6, 2016 v0 v0.12.0 Apr 4, 2016 Changes in this version type BasicClient + RetentionPolicy string v0.11.0-rc1 Mar 15, 2016 v0.10.3 Mar 9, 2016 v0.10.2 Mar 3, 2016 v0.10.0 Feb 4, 2016 Changes in this version + func NewOutputConfig() *outputConfig + type AbstractField struct + Key string + Type string + type AbstractFields []AbstractField + func (f AbstractFields) Template() (string, []string) + type AbstractTag struct + Key string + Value string + type AbstractTags []AbstractTag + func (t AbstractTags) Template() string + type BasicClient struct + Addresses []string + BatchInterval string + BatchSize int + Concurrency int + Database string + Enabled bool + Format string + Precision string + SSL bool + func (b *BasicClient) BasicWriteHandler(rs <-chan response, wt *Timer) + func (c *BasicClient) Batch(ps <-chan Point, r chan<- response) error + type BasicPointGenerator struct + Fields AbstractFields + Jitter bool + Measurement string + PointCount int + Precision string + SeriesCount int + StartDate string + Tags AbstractTags + Tick string + func (b *BasicPointGenerator) Generate() (<-chan Point, error) + func (b *BasicPointGenerator) Template() func(i int, t time.Time) *Pnt + func (b *BasicPointGenerator) Time() time.Time + type BasicProvisioner struct + Address string + Database string + Enabled bool + ResetDatabase bool + func (b *BasicProvisioner) Provision() error + type BasicQuery struct + QueryCount int + Template Query + func (q *BasicQuery) QueryGenerate(now func() time.Time) (<-chan Query, error) + func (q *BasicQuery) SetTime(t time.Time) + type BasicQueryClient struct + Addresses []string + Concurrency int + Database string + Enabled bool + QueryInterval string + func (b *BasicQueryClient) BasicReadHandler(r <-chan response, rt *Timer) + func (b *BasicQueryClient) Exec(qs <-chan Query, r chan<- response) error + func (b *BasicQueryClient) Init() error + func (b *BasicQueryClient) Query(cmd Query) (response, error) + type BroadcastChannel struct + func NewBroadcastChannel() *BroadcastChannel + func (b *BroadcastChannel) Broadcast(r response) + func (b *BroadcastChannel) Close() + func (b *BroadcastChannel) Handle(rs <-chan response, t *Timer) + func (b *BroadcastChannel) Register(fn responseHandler) type Config + Provision Provision + Read Read + func BasicStress() (*Config, error) + func DecodeConfig(s string) (*Config, error) + type Field KeyValue + type Fields []Field + type InfluxClient interface + Batch func(ps <-chan Point, r chan<- response) error + type InfluxClients struct + Basic BasicClient + type KeyValue struct + Key string + Value string + type Pnt struct + func (p *Pnt) Next(i int, t time.Time) + func (p *Pnt) Set(b []byte) + func (p Pnt) Graphite() []byte + func (p Pnt) Line() []byte + func (p Pnt) OpenJSON() []byte + func (p Pnt) OpenTelnet() []byte + type Point interface + Graphite func() []byte + Line func() []byte + OpenJSON func() []byte + OpenTelnet func() []byte + type PointGenerator interface + Generate func() (<-chan Point, error) + Time func() time.Time + type PointGenerators struct + Basic BasicPointGenerator + type Provision struct + Basic BasicProvisioner + type Provisioner interface + Provision func() error + type Querier struct + func NewQuerier(q QueryGenerator, c QueryClient) Querier + type Query string + type QueryClient interface + Exec func(qs <-chan Query, r chan<- response) error + Query func(q Query) (response, error) + type QueryClients struct + Basic BasicQueryClient + type QueryGenerator interface + QueryGenerate func(f func() time.Time) (<-chan Query, error) + SetTime func(t time.Time) + type QueryGenerators struct + Basic BasicQuery + type QueryResponse struct + Body string + func (r QueryResponse) Success() bool + type Read struct + QueryClients QueryClients + QueryGenerators QueryGenerators + type StdPoint struct + Fields Fields + Measurement string + Tags Tags + Timestamp int64 + func (p StdPoint) Graphite() []byte + func (p StdPoint) Line() []byte + func (p StdPoint) OpenJSON() []byte + func (p StdPoint) OpenTelnet() []byte + type StressTest struct + func NewStressTest(p Provisioner, w Writer, r Querier) StressTest + func (s *StressTest) Start(wHandle responseHandler, rHandle responseHandler) + type Tag KeyValue + type Tags []Tag + type Write struct + InfluxClients InfluxClients + PointGenerators PointGenerators + type WriteResponse response + type Writer struct + func NewWriter(p PointGenerator, i InfluxClient) Writer v0.10.0-rc2 Feb 2, 2016 v0.10.0-beta2 Jan 23, 2016 v0.10.0-beta1 Jan 13, 2016 v0.9.6-rc1 Dec 7, 2015 v0.9.5 Nov 17, 2015 Changes in this version + func MeasurementQuery(cfg *Config, timestamp chan time.Time, results chan QueryResults) + func NewSeries(m string, p int, sc int) series + func Run(cfg *Config, done chan struct{}, ts chan time.Time) (totalPoints int, failedRequests int, responseTimes ResponseTimes, timer *Timer) + func SeriesQuery(cfg *Config, done chan struct{}, results chan QueryResults) + type ConcurrencyLimiter struct + func NewConcurrencyLimiter(max int) *ConcurrencyLimiter + func (c *ConcurrencyLimiter) Decrement() + func (c *ConcurrencyLimiter) Increment() + type Config struct + ChannelBufferSize int + MeasurementQuery measurementQuery + SSL bool + Series []series + SeriesQuery seriesQuery + Write write + func DecodeFile(s string) (*Config, error) + func NewConfig() *Config + func (cfg *Config) NewClient() (*client.Client, error) + type Measurements []string + func (ms *Measurements) Set(value string) error + func (ms *Measurements) String() string + type QueryResults struct + ResponseTimes ResponseTimes + TotalQueries int + type ResponseTime struct + Time time.Time + Value int + func NewResponseTime(v int) ResponseTime + type ResponseTimes []ResponseTime + func (rs ResponseTimes) Len() int + func (rs ResponseTimes) Less(i, j int) bool + func (rs ResponseTimes) Swap(i, j int) + type Timer struct + func NewTimer() *Timer + func (t *Timer) Elapsed() time.Duration + func (t *Timer) End() time.Time + func (t *Timer) Start() time.Time + func (t *Timer) StartTimer() + func (t *Timer) StopTimer() v0.9.5-rc3 Nov 16, 2015
Go to main page