tracker

Dec 22, 2025

Changes in this version

+ const ReadBufferSize

+ type FlowEventFilter func(flow *ct.Flow) bool

+ type FlowTracker struct

+ func New(nodeIter NodeIterator, filter FlowEventFilter, ...) (*FlowTracker, error)

+ func (c *FlowTracker) Close() error

+ func (c *FlowTracker) TrackConnections() error

+ type NodeIterator func(func(node *models.CommonNode) bool)

+ type ParticipantEnricher func(addr netip.Addr) *pbflow.FlowParticipant