out

Documentation

Index

• func GetCompression(codec string) sarama.CompressionCodec
• type FanOut
  • func NewFanOut(outs []Out) FanOut
  • func (f FanOut) Close() error
  • func (f FanOut) Flush(metrics []*schema.MetricData) error
• type OffsetFilter
  • func NewOffsetFilter(out Out, opts string) (OffsetFilter, error)
  • func (of OffsetFilter) Close() error
  • func (of OffsetFilter) Flush(metrics []*schema.MetricData) error
• type Out
• type OutStats
  • func NewStats(stats met.Backend, output string) OutStats

Functions

func GetCompression

func GetCompression(codec string) sarama.CompressionCodec

Types

type FanOut

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

func NewFanOut

func NewFanOut(outs []Out) FanOut

func (FanOut) Close

func (f FanOut) Close() error

func (FanOut) Flush

func (f FanOut) Flush(metrics []*schema.MetricData) error

type OffsetFilter

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

func NewOffsetFilter

func NewOffsetFilter(out Out, opts string) (OffsetFilter, error)

func (OffsetFilter) Close

func (of OffsetFilter) Close() error

func (OffsetFilter) Flush

func (of OffsetFilter) Flush(metrics []*schema.MetricData) error

type Out

type Out interface {
	Close() error
	// Flush completely handles the metrics, does not keep references into it, so that caller can reuse
	// Filter outputs reserve the right to make in-place modifications
	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