encode

Documentation

Index

• type EncodeProm
  • func (e *EncodeProm) Cleanup(sourceEntry interface{})
  • func (e *EncodeProm) Encode(metrics []config.GenericMap)
  • func (e *EncodeProm) EncodeMetric(metricRecord config.GenericMap) []config.GenericMap
• type Encoder
  • func NewEncodeKafka(params config.StageParam) (Encoder, error)
  • func NewEncodeNone() (Encoder, error)
  • func NewEncodeProm(params config.StageParam) (Encoder, error)
• type PromMetric

Types

type EncodeProm

type EncodeProm struct {
	PrevRecords []config.GenericMap
	// contains filtered or unexported fields
}

func (*EncodeProm) Cleanup

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

callback function from lru cleanup

func (*EncodeProm) Encode

func (e *EncodeProm) Encode(metrics []config.GenericMap)

Encode encodes a metric before being stored

func (*EncodeProm) EncodeMetric

func (e *EncodeProm) EncodeMetric(metricRecord config.GenericMap) []config.GenericMap

type Encoder

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

func NewEncodeKafka

func NewEncodeKafka(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(params config.StageParam) (Encoder, error)

type PromMetric

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