sink

Documentation

Index

• func BuildSink(cfg *conf.SpoonConfigSink) (interface{}, error)
• type LoggingSink
  • func NewLoggingSink() *LoggingSink
  • func (s *LoggingSink) Gauge(path string, value interface{})
• type Metric
• type Sink
• type StatsdSink
  • func NewStatsdSink(cfg *conf.SpoonConfigSink) (*StatsdSink, error)
  • func (s *StatsdSink) Gauge(path string, value interface{})
• type StatsdSinkSettings

Functions

func BuildSink

func BuildSink(cfg *conf.SpoonConfigSink) (interface{}, error)

Types

type LoggingSink

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

LoggingSink is an implementation of sync which just logs data points to the standard logging output.

func NewLoggingSink

func NewLoggingSink() *LoggingSink

NewLoggingSink constructs a new Logging metric sink. A logging sink does not send metrics anywhere but simply logs them at info level to the module logger.

func (*LoggingSink) Gauge

func (s *LoggingSink) Gauge(path string, value interface{})

Gauge writes a path/value pair to the log

type Metric

type Metric struct {
	Path      string
	Value     float64
	Timestamp int64
}

type Sink

type Sink interface {
	Gauge(bucket string, value interface{})
}

A Sink is an object that acts as the destination for results from the agents.

type StatsdSink

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

func NewStatsdSink

func NewStatsdSink(cfg *conf.SpoonConfigSink) (*StatsdSink, error)

func (*StatsdSink) Gauge

func (s *StatsdSink) Gauge(path string, value interface{})

Gauge writes a path/value pair to the log

type StatsdSinkSettings

type StatsdSinkSettings struct {
	Address string `json:"address"`
}