Versions in this module Expand all Collapse all v0 v0.2.1 Nov 16, 2015 v0.2.0 Oct 27, 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()