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) Closed() bool

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

Sep 7, 2016

Changes in this version

+ const DefaultBatchPending

+ const DefaultBatchSize

+ const DefaultBatchTimeout

+ const DefaultBindAddress

+ const DefaultDatabase

+ const DefaultPrecision

+ const DefaultReadBuffer

+ const DefaultRetentionPolicy

+ const MAX_UDP_PAYLOAD

type Config

+ BatchPending int

+ Precision string

+ ReadBuffer int

+ RetentionPolicy string

+ func NewConfig() Config

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

type Service

+ MetaClient interface{ ... }

+ 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

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)