encode

Documentation

Index

• type EncodeProm
  • func (e *EncodeProm) Cleanup(cleanupFunc interface{})
  • func (e *EncodeProm) Encode(metricRecord config.GenericMap)
• type Encoder
  • func NewEncodeKafka(opMetrics *operational.Metrics, params config.StageParam) (Encoder, error)
  • func NewEncodeNone() (Encoder, error)
  • func NewEncodeProm(opMetrics *operational.Metrics, params config.StageParam) (Encoder, error)
  • func NewEncodeS3(opMetrics *operational.Metrics, params config.StageParam) (Encoder, error)

Types

type EncodeProm

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

func (*EncodeProm) Cleanup

func (e *EncodeProm) Cleanup(cleanupFunc interface{})

callback function from lru cleanup

func (*EncodeProm) Encode

func (e *EncodeProm) Encode(metricRecord config.GenericMap)

Encode encodes a metric before being stored

type Encoder

type Encoder interface {
	Encode(in config.GenericMap)
}

func NewEncodeKafka

func NewEncodeKafka(opMetrics *operational.Metrics, params config.StageParam) (Encoder, error)

NewEncodeKafka create a new writer to kafka

func NewEncodeNone

func NewEncodeNone() (Encoder, error)

NewEncodeNone create a new encode

func NewEncodeProm

func NewEncodeProm(opMetrics *operational.Metrics, params config.StageParam) (Encoder, error)

func NewEncodeS3

func NewEncodeS3(opMetrics *operational.Metrics, params config.StageParam) (Encoder, error)

NewEncodeS3 creates a new writer to S3