PR #11171 introduced initial multi-node support for hubble-relay. However, with the existing implementation, flows are forwarded as they are received from hubble peers. This means that flows are typically not chronologically sorted.
Hubble's priority queue implementation for flows (pkg/hubble/container/priority_queue.go should be leveraged to re-order flows on a best effort basis (ie: one should buffer up to N flows before forwarding them).
PR #11171 introduced initial multi-node support for hubble-relay. However, with the existing implementation, flows are forwarded as they are received from hubble peers. This means that flows are typically not chronologically sorted.
Hubble's priority queue implementation for flows (
pkg/hubble/container/priority_queue.goshould be leveraged to re-order flows on a best effort basis (ie: one should buffer up to N flows before forwarding them).