udp

Jun 21, 2017

Changes in this version

+ const MaxUDPPayload

+ type Configs []Config

+ func (c Configs) Diagnostics() (*diagnostics.Diagnostics, error)

+ func (c Configs) Enabled() bool

Apr 17, 2017

Changes in this version

type Service

+ func (s *Service) WithLogger(log zap.Logger)

Dec 6, 2016

Changes in this version

type Service

+ func (s *Service) Closed() bool

Sep 7, 2016

Changes in this version

+ const MAX_UDP_PAYLOAD

type Service

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

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

+ type Statistics struct

+ BatchesTransmitFail int64

+ BatchesTransmitted int64

+ BytesReceived int64

+ PointsParseFail int64

+ PointsReceived int64

+ PointsTransmitted int64

+ ReadFail int64

Apr 4, 2016

Changes in this version

+ const DefaultBindAddress

+ const DefaultPrecision

+ const DefaultRetentionPolicy

type Config

+ Precision string

+ func NewConfig() Config

Feb 4, 2016

Changes in this version

+ const DefaultUDPPayloadSize

type Config

+ UDPPayloadSize int

type Service

+ MetaClient interface{ ... }

Nov 17, 2015

Changes in this version

+ const DefaultBatchPending

+ const DefaultBatchSize

+ const DefaultBatchTimeout

+ const DefaultDatabase

+ const DefaultReadBuffer

type Config

+ BatchPending int

+ ReadBuffer int

+ RetentionPolicy string

+ func (c *Config) WithDefaults() *Config

type Service

+ MetaStore interface{ ... }

Jul 24, 2015

Changes in this version

+ const UDPBufferSize

+ type Config struct

+ BatchSize int

+ BatchTimeout toml.Duration

+ BindAddress string

+ Database string

+ Enabled bool

+ type Service struct

+ Logger *log.Logger

+ PointsWriter interface{ ... }

+ func NewService(c Config) *Service

+ func (s *Service) Addr() net.Addr

+ func (s *Service) Close() error

+ func (s *Service) Open() (err error)

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