Versions in this module Expand all Collapse all v1 v1.1.2 May 1, 2018 v1.1.1 Dec 21, 2016 v1.1.0 May 31, 2016 Changes in this version + const DefaultRetries + var ErrNotInfluxError = errors.New("outflux: error is not an InfluxDB error") + var Stdlog = stdlog + func DefaultBackoff(retry, maxRetries int) time.Duration + func SendMeasurements(ctx context.Context, url *url.URL, client *http.Client, ...) (err error) + func SetWriter(w *Proxy) + func Write(b []byte) (int, error) + func WriteMeasurement(m dagr.Measurement) (int64, error) + func WriteMeasurements(ms ...dagr.Measurement) (int64, error) + func WritePoint(key string, when time.Time, tags dagr.Tags, fields dagr.Fields) (n int64, err error) + type BackoffFunc func(retry, maxRetries int) time.Duration + var DefaultBackoffFunc BackoffFunc = DefaultBackoff + type BadStatusError struct + Body []byte + Code int + Err error + func (e *BadStatusError) Error() string + func (e *BadStatusError) InfluxError() (*InfluxError, error) + type Director func(*http.Request) error + type FixedBackoff time.Duration + func (d FixedBackoff) Backoff(int, int) time.Duration + type FlushSize int + type InfluxError struct + Error string + type Logger interface + Print func(...interface{}) + var Log Logger + type Option interface + func RequestLimit(n int) Option + type Proxy struct + func New(client *http.Client, destURL string, opts ...Option) *Proxy + func NewURL(client *http.Client, destURL *url.URL, opts ...Option) *Proxy + func (w *Proxy) Flush(ctx context.Context) error + func (w *Proxy) Start(ctx context.Context, interval time.Duration) + func (w *Proxy) Transaction(fn WriteFunc) (err error) + func (w *Proxy) Write(b []byte) (int, error) + func (w *Proxy) WriteMeasurement(measurement dagr.Measurement) (n int64, err error) + func (w *Proxy) WriteMeasurements(measurements ...dagr.Measurement) (n int64, err error) + func (w *Proxy) WritePoint(key string, when time.Time, tags dagr.Tags, fields dagr.Fields) (n int64, err error) + func (w *Proxy) Writer() io.WriteCloser + type RetryLimit int + type Timeout time.Duration + type WriteFunc func(io.Writer) error
Go to main page