Versions in this module Expand all Collapse all v1 v1.0.0 Jul 30, 2020 Changes in this version + func GetCompression(codec string) sarama.CompressionCodec + type FanOut struct + func NewFanOut(outs []Out) FanOut + func (f FanOut) Close() error + func (f FanOut) Flush(metrics []*schema.MetricData) error + type OffsetFilter struct + func NewOffsetFilter(out Out, opts string) (OffsetFilter, error) + func (of OffsetFilter) Close() error + func (of OffsetFilter) Flush(metrics []*schema.MetricData) error + type Out interface + Close func() error + Flush func(metrics []*schema.MetricData) error + type OutStats struct + FlushDuration met.Timer + MessageBytes met.Meter + MessageMetrics met.Meter + PublishDuration met.Timer + PublishErrors met.Count + PublishQueued met.Gauge + PublishedMessages met.Count + PublishedMetrics met.Count + func NewStats(stats met.Backend, output string) OutStats
Go to main page