statsd

Documentation

Index

• type Aggregator
  • func NewAggregator(t dataPointQueuer, prefix string) *Aggregator
  • func (a *Aggregator) Flush()
  • func (a *Aggregator) Process(st *Stat) error
• type Stat
  • func ParseStatsdPacket(packet string) (*Stat, error)
  • func (st *Stat) GobDecode(b []byte) error
  • func (st *Stat) GobEncode() ([]byte, error)

Types

type Aggregator

type Aggregator struct {
	// contains filtered or unexported fields
}

func NewAggregator

func NewAggregator(t dataPointQueuer, prefix string) *Aggregator

func (*Aggregator) Flush

func (a *Aggregator) Flush()

func (*Aggregator) Process

func (a *Aggregator) Process(st *Stat) error

type Stat

type Stat struct {
	Name   string
	Value  float64
	Metric string
	Sample float64
	Hops   int
}

func ParseStatsdPacket

func ParseStatsdPacket(packet string) (*Stat, error)

ParseStatsdPacket parses a statsd packet e.g: gorets:1|c|@0.1. See https://github.com/etsy/statsd/blob/master/docs/metric_types.md There is no need to support multi-metric packets here, since it uses newline as separator, the text handler in daemon/services.go would take care of it.

func (*Stat) GobDecode

func (st *Stat) GobDecode(b []byte) error

func (*Stat) GobEncode

func (st *Stat) GobEncode() ([]byte, error)

TODO Why do we need these if all the members are public base types?