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.GetChannels())

// ...

statsd.Stop()

Documentation

Index

• type Server
  • func NewServer(metricOut chan<- *metrics.MetricSample, eventOut chan<- metrics.Event, ...) (*Server, error)
  • func (s *Server) Stop()

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(metricOut chan<- *metrics.MetricSample, eventOut chan<- metrics.Event, serviceCheckOut chan<- metrics.ServiceCheck) (*Server, error)

NewServer returns a running Dogstatsd server

func (*Server) Stop

func (s *Server) Stop()

Stop stops a running Dogstatsd server