-
- Downloads
Fix issue with inconsistent GenericMap output (#297)
* Fix issue with inconsistent GenericMap output The FLP GenericMap provided by the agent differs in types depending on the exporter being used, especially with DirectFLP each records size is smaller than when used with protobuf, due to protobuf using uint32 almost everywhere. This is not a problem in most cases as FLP generally converts that in JSON, but it breaks the FLP IPFIX export which expects strict types. This commit brings more consistency between the FLP-direct mode and the protobuf mode, by sharing the same GenericMap encoding function. Which means the protobuf decode is now done in two steps: first proto-to-flow.Record, then flow.Record-to-GenericMap. * fix proto decode test
Showing
- docs/config.md 1 addition, 1 deletiondocs/config.md
- pkg/decode/decode_protobuf.go 63 additions, 72 deletionspkg/decode/decode_protobuf.go
- pkg/decode/decode_protobuf_test.go 11 additions, 11 deletionspkg/decode/decode_protobuf_test.go
- pkg/exporter/convert_flp.go 0 additions, 101 deletionspkg/exporter/convert_flp.go
- pkg/exporter/converters_test.go 14 additions, 7 deletionspkg/exporter/converters_test.go
- pkg/exporter/direct_flp.go 2 additions, 1 deletionpkg/exporter/direct_flp.go
- pkg/exporter/grpc_proto.go 2 additions, 1 deletionpkg/exporter/grpc_proto.go
- pkg/exporter/kafka_proto.go 2 additions, 1 deletionpkg/exporter/kafka_proto.go
- pkg/exporter/kafka_proto_test.go 6 additions, 13 deletionspkg/exporter/kafka_proto_test.go
- pkg/flow/record.go 7 additions, 0 deletionspkg/flow/record.go
- pkg/pbflow/proto.go 202 additions, 0 deletionspkg/pbflow/proto.go
- vendor/github.com/netobserv/flowlogs-pipeline/pkg/pipeline/write/write_ipfix.go 0 additions, 1 deletion...bserv/flowlogs-pipeline/pkg/pipeline/write/write_ipfix.go
Loading
Please register or sign in to comment