dogstatsd

README

package dogstatsd

This package is responsible for receiving metrics from external software over UDP. Every package has to follow the Dogstatsd format: http://docs.datadoghq.com/guides/dogstatsd/.

Metrics will be sent to the aggregator just like regular metrics from checks. This mean that aggregator and forwarder configuration will also inpact Dogstatsd.

Usage example:

// you must first initialize the aggregator, see aggregator.InitAggregator

// This will return an already running statd server ready to receive metrics
statsd, err := dogstatsd.NewServer(aggregatorInstance.GetBufferedChannels())

// ...

statsd.Stop()

Documentation

Index

• func FormatDebugStats(stats []byte) (string, error)
• type Server
  • func NewServer(samplePool *metrics.MetricSamplePool, samplesOut chan<- []metrics.MetricSample, ...) (*Server, error)
  • func (s *Server) GetJSONDebugStats() ([]byte, error)
  • func (s *Server) Stop()

Functions

func FormatDebugStats

func FormatDebugStats(stats []byte) (string, error)

FormatDebugStats returns a printable version of debug stats.

Types

type Server

type Server struct {
	Statistics *util.Stats
	Started    bool
	// contains filtered or unexported fields
}

Server represent a Dogstatsd server

func NewServer

func NewServer(samplePool *metrics.MetricSamplePool, samplesOut chan<- []metrics.MetricSample, eventsOut chan<- []*metrics.Event, servicesCheckOut chan<- []*metrics.ServiceCheck) (*Server, error)

NewServer returns a running Dogstatsd server

func (*Server) GetJSONDebugStats

func (s *Server) GetJSONDebugStats() ([]byte, error)

GetJSONDebugStats returns jsonified debug statistics.

func (*Server) Stop

func (s *Server) Stop()

Stop stops a running Dogstatsd server