Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 NewEncodeProm ¶
func NewEncodeProm(opMetrics *operational.Metrics, params config.StageParam) (Encoder, error)
Source Files
Click to show internal directories.
Click to hide internal directories.