flow: make input decode flows

We cannot pass the payload around as we want to reuse it. We should
pass a copy, but this is a bit of a waste. Just do decoding during
input ingestion. The CPU usage should be small, this helps locality
and it avoids one channel.
This commit is contained in:
Vincent Bernat
2022-03-26 15:18:52 +01:00
parent 176e4999b9
commit 1b4ba973a7
15 changed files with 146 additions and 114 deletions

View File

@@ -73,10 +73,6 @@ The flow component handles flow ingestion. It supports the following
configuration keys:
- `inputs` to specify the list of inputs
- `workers` to specify the number of workers to spawn to handle
decoding
- `queue-size` to specify the number of flows to queue when pushing
them to the core component
Each input should define a `type` and `decoder`. For `decoder`, only
`netflow` is currently supported. As for the `type`, both `udp` and