Versions in this module Expand all Collapse all v1 v1.1.0 Mar 2, 2017 Changes in this version + var AggregatesLookup = map[string]Aggregate + type Aggregate int + const AggregateAverage + const AggregateCount + const AggregateMax + const AggregateMedian + const AggregateMin + const AggregateSum + type Counter struct + Name string + Tags []string + func NewCounter(Name string, Tags []string) *Counter + func (c *Counter) Combine(other []byte) error + func (c *Counter) Export() (JSONMetric, error) + func (c *Counter) Flush(interval time.Duration) []DDMetric + func (c *Counter) Sample(sample float64, sampleRate float32) + type DDMetric struct + DeviceName string + Hostname string + Interval int32 + MetricType string + Name string + Tags []string + Value [1][2]float64 + type Gauge struct + Name string + Tags []string + func NewGauge(Name string, Tags []string) *Gauge + func (g *Gauge) Flush() []DDMetric + func (g *Gauge) Sample(sample float64, sampleRate float32) + type Histo struct + LocalMax float64 + LocalMin float64 + LocalSum float64 + LocalWeight float64 + Name string + Tags []string + Value *tdigest.MergingDigest + func NewHist(Name string, Tags []string) *Histo + func (h *Histo) Combine(other []byte) error + func (h *Histo) Export() (JSONMetric, error) + func (h *Histo) Flush(interval time.Duration, percentiles []float64, aggregates HistogramAggregates) []DDMetric + func (h *Histo) Sample(sample float64, sampleRate float32) + type HistogramAggregates struct + Count int + Value Aggregate + type JSONMetric struct + Tags []string + Value []byte + type MetricKey struct + JoinedTags string + Name string + Type string + type MetricScope int + const GlobalOnly + const LocalOnly + const MixedScope + type Set struct + Hll *hyperloglog.HyperLogLogPlus + Name string + Tags []string + func NewSet(Name string, Tags []string) *Set + func (s *Set) Combine(other []byte) error + func (s *Set) Export() (JSONMetric, error) + func (s *Set) Flush() []DDMetric + func (s *Set) Sample(sample string, sampleRate float32) + type SplitBytes struct + func NewSplitBytes(buf []byte, delim byte) *SplitBytes + func (sb *SplitBytes) Chunk() []byte + func (sb *SplitBytes) Next() bool + type UDPEvent struct + Aggregation string + AlertLevel string + Hostname string + Priority string + Source string + Tags []string + Text string + Timestamp int64 + Title string + func ParseEvent(packet []byte) (*UDPEvent, error) + type UDPMetric struct + Digest uint32 + SampleRate float32 + Scope MetricScope + Tags []string + Value interface{} + func ParseMetric(packet []byte) (*UDPMetric, error) + type UDPServiceCheck struct + Hostname string + Message string + Name string + Status int + Tags []string + Timestamp int64 + func ParseServiceCheck(packet []byte) (*UDPServiceCheck, error)