out

Documentation

Index

• func GetCompression(codec string) sarama.CompressionCodec
• type Out
• type OutStats
  • func NewStats(stats met.Backend, output string) OutStats

Functions

func GetCompression

func GetCompression(codec string) sarama.CompressionCodec

Types

type Out

type Out interface {
	Close() error
	//output completely handles the data so that caller can reuse
	Flush(metrics []*schema.MetricData) error
}

Out submits metricdata to a destination

type OutStats

type OutStats struct {
	FlushDuration     met.Timer // duration of Flush()
	PublishQueued     met.Gauge // not every output uses this
	PublishErrors     met.Count // not every output uses this
	PublishDuration   met.Timer // duration of writing a message to underlying storage
	PublishedMetrics  met.Count // number of metrics written to underlying storage
	PublishedMessages met.Count // number of messages written to underlying storage
	MessageBytes      met.Meter // number of bytes per message
	MessageMetrics    met.Meter // number of metrics per message
}

OutStats tracks metrics related to an Output

func NewStats

func NewStats(stats met.Backend, output string) OutStats

NewStats creates a new OutStats