subscriber

Nov 11, 2016

Changes in this version

type Config

+ CaCerts string

+ InsecureSkipVerify bool

type HTTP

+ func NewHTTPS(addr string, timeout time.Duration, unsafeSsl bool, caCerts string) (*HTTP, error)

Oct 5, 2016

Changes in this version

+ const DefaultWriteBufferSize

+ const DefaultWriteConcurrency

type Config

+ WriteBufferSize int

+ WriteConcurrency int

Sep 7, 2016

Changes in this version

+ const DefaultHTTPTimeout

type Config

+ HTTPTimeout toml.Duration

+ func (c Config) Validate() error

+ type HTTP struct

+ func NewHTTP(addr string, timeout time.Duration) (*HTTP, error)

+ func (h *HTTP) WritePoints(p *coordinator.WritePointsRequest) (err error)

type Service

+ func (s *Service) Statistics(tags map[string]string) []models.Statistic

+ type Statistics struct

+ PointsWritten int64

+ WriteFailures int64

May 11, 2016

Changes in this version

type Service

+ func (s *Service) SetLogOutput(w io.Writer)

Feb 4, 2016

Changes in this version

type Service

+ MetaClient interface{ ... }

Nov 17, 2015

Changes in this version

+ type BalanceMode int

+ const ALL

+ const ANY

+ type Config struct

+ Enabled bool

+ func NewConfig() Config

+ type PointsWriter interface

+ WritePoints func(p *cluster.WritePointsRequest) error

+ type Service struct

+ Logger *log.Logger

+ MetaStore interface{ ... }

+ NewPointsWriter func(u url.URL) (PointsWriter, error)

+ func NewService(c Config) *Service

+ func (s *Service) Close() error

+ func (s *Service) Open() error

+ func (s *Service) Points() chan<- *cluster.WritePointsRequest

+ func (s *Service) SetLogger(l *log.Logger)

+ func (s *Service) Update() error

+ type UDP struct

+ func NewUDP(addr string) *UDP

+ func (u *UDP) WritePoints(p *cluster.WritePointsRequest) (err error)