serializers

Documentation

Index

• type Config
• type Serializer
  • func NewGraphiteSerializer(prefix, template string) (Serializer, error)
  • func NewInfluxSerializer() (Serializer, error)
  • func NewJsonSerializer(timestampUnits time.Duration) (Serializer, error)
  • func NewSerializer(config *Config) (Serializer, error)
• type SerializerOutput

Types

type Config

type Config struct {
	// Dataformat can be one of: influx, graphite, or json
	DataFormat string

	// Prefix to add to all measurements, only supports Graphite
	Prefix string

	// Template for converting telegraf metrics into Graphite
	// only supports Graphite
	Template string

	// Timestamp units to use for JSON formatted output
	TimestampUnits time.Duration
}

Config is a struct that covers the data types needed for all serializer types, and can be used to instantiate _any_ of the serializers.

type Serializer

type Serializer interface {
	// Serialize takes a single telegraf metric and turns it into a byte buffer.
	// separate metrics should be separated by a newline, and there should be
	// a newline at the end of the buffer.
	Serialize(metric telegraf.Metric) ([]byte, error)
}

Serializer is an interface defining functions that a serializer plugin must satisfy.

func NewGraphiteSerializer

func NewGraphiteSerializer(prefix, template string) (Serializer, error)

func NewInfluxSerializer

func NewInfluxSerializer() (Serializer, error)

func NewJsonSerializer

func NewJsonSerializer(timestampUnits time.Duration) (Serializer, error)

func NewSerializer

func NewSerializer(config *Config) (Serializer, error)

NewSerializer a Serializer interface based on the given config.

type SerializerOutput

type SerializerOutput interface {
	// SetSerializer sets the serializer function for the interface.
	SetSerializer(serializer Serializer)
}

SerializerOutput is an interface for output plugins that are able to serialize telegraf metrics into arbitrary data formats.