decode

type DecodeJson ¶

type DecodeJson struct {
	PrevRecords []interface{}
}

func (c *DecodeJson) Decode(in []interface{}) []config.GenericMap

type Decoder ¶

type Decoder interface {
	Decode(in []interface{}) []config.GenericMap
}

func GetDecoder(params api.Decoder) (Decoder, error)

func NewDecodeJson() (Decoder, error)

type Protobuf ¶

type Protobuf struct {
}

Protobuf decodes protobuf flow records definitions, as forwarded by ingest.NetObservAgent, into a Generic Map that follows the same naming conventions as the IPFIX flows from ingest.IngestCollector

func NewProtobuf() (*Protobuf, error)

func (p *Protobuf) Decode(in []interface{}) []config.GenericMap