out

package
Version: v0.0.0-...-53bceb3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 2, 2020 License: Apache-2.0 Imports: 5 Imported by: 0

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
	//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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL