statsd

package
v0.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 17, 2017 License: BSD-3-Clause Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// UDPMaxPacketSize means UDP packet limit, see https://en.wikipedia.org/wiki/User_Datagram_Protocol#Packet_structure
	UDPMaxPacketSize int = 64 * 1024

	// AllowedPendingMessages is the number of UDP messages allowed to queue up, once filled, the statsd server will start dropping packets
	AllowedPendingMessages = 10000
)

Variables

This section is empty.

Functions

func NewAggregator 

func NewAggregator(
	metrics chan metric.Metric,
	conf *config.Config,
) metric.Aggregator

NewAggregator XXX

Types

type Payload 

type Payload struct {
	Series []interface{} `json:"series"`
}

Payload XXX

type Reporter 

type Reporter struct {
	*emitter.Emitter
	// contains filtered or unexported fields
}

Reporter XXX

func NewReporter 

func NewReporter(conf *config.Config) *Reporter

NewReporter creates a new instance of Reporter.

func (*Reporter) Post 

func (r *Reporter) Post(metrics []interface{}) error

Post sends the metrics to Forwarder API.

type Statsd 

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

Statsd XXX

func NewStatsd 

func NewStatsd(conf *config.Config) *Statsd

NewStatsd XXX

func (*Statsd) Run 

func (s *Statsd) Run(shutdown chan struct{}) error

Run XXX

Source Files

  • aggregator.go
  • payload.go
  • reporter.go
  • statsd.go

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.