Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetCompression ¶
func GetCompression(codec string) sarama.CompressionCodec
Types ¶
type Out ¶
type Out interface {
Close() error
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
Click to show internal directories.
Click to hide internal directories.