decode

type DecodeJson ¶

type DecodeJson struct {
}

func (c *DecodeJson) Decode(line []byte) (config.GenericMap, error)

type Decoder ¶

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

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(rawFlow []byte) (config.GenericMap, error)