encode

Documentation

Index

• Variables
• func ExtractLabelsAndKey(flow config.GenericMap, info *api.MetricsItem) (map[string]string, string)
• 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)
• type MetricInfo
  • func CreateMetricInfo(def api.MetricsItem) *MetricInfo
• type Predicate
  • func Absence(filter api.MetricsFilter) Predicate
  • func Exact(filter api.MetricsFilter) Predicate
  • func Presence(filter api.MetricsFilter) Predicate

Variables

var (
	MetricsProcessed = operational.DefineMetric(
		"metrics_processed",
		"Number of metrics processed",
		operational.TypeCounter,
		"stage",
	)
	MetricsDropped = operational.DefineMetric(
		"metrics_dropped",
		"Number of metrics dropped",
		operational.TypeCounter,
		"stage",
	)
	EncodePromErrors = operational.DefineMetric(
		"encode_prom_errors",
		"Total errors during metrics generation",
		operational.TypeCounter,
		"error", "metric", "key",
	)
)

Functions

func ExtractLabelsAndKey

func ExtractLabelsAndKey(flow config.GenericMap, info *api.MetricsItem) (map[string]string, string)

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

type MetricInfo

type MetricInfo struct {
	api.MetricsItem
	FilterPredicates []Predicate
}

func CreateMetricInfo

func CreateMetricInfo(def api.MetricsItem) *MetricInfo

type Predicate

type Predicate func(flow config.GenericMap) bool

func Absence

func Absence(filter api.MetricsFilter) Predicate

func Exact

func Exact(filter api.MetricsFilter) Predicate

func Presence

func Presence(filter api.MetricsFilter) Predicate