Struct XdpMultiSessionStream 

pub struct XdpMultiSessionStream<E, F>
where
    E: FlowExtractor,
    E::Key: Eq + Hash + Clone + Send + 'static,
    F: SessionParserFactory<E::Key>,
{ /* private fields */ }

Tagged fan-in of AF_XDP SessionStreams (issue #104).

Implementations

impl<E, F> XdpMultiSessionStream<E, F>

where E: FlowExtractor + Clone + Unpin + Send + 'static, E::Key: Eq + Hash + Clone + Unpin + Send + 'static, F: SessionParserFactory<E::Key> + Clone + Unpin + Send + 'static, F::Parser: Unpin + Send + 'static, <F::Parser as SessionParser>::Message: Unpin + Send + 'static,

pub fn label(&self, source_idx: u16) -> Option<&str>

Label (interface name) for source_idx.

pub fn alive_sources(&self) -> usize

Number of sources still being polled.

pub fn per_source_capture_stats( &self, ) -> Vec<(String, Option<Result<CaptureStats, Error>>)>

Per-source kernel-ring stats (summed across each capture’s RX queues).

pub fn per_source_tracker_stats( &self, ) -> Vec<(String, Option<&FlowTrackerStats>)>

Per-source tracker stats.

pub fn total_active_flows(&self) -> usize

Sum of live flow counts across all sources.

Trait Implementations

impl<E, F> Stream for XdpMultiSessionStream<E, F>

where E: FlowExtractor + Unpin, E::Key: Eq + Hash + Clone + Send + 'static + Unpin, F: SessionParserFactory<E::Key> + Unpin, F::Parser: Unpin, <F::Parser as SessionParser>::Message: Unpin,

Available on crate features af-xdp and xdp-loader only.

type Item = Result<TaggedEvent<SessionEvent<<E as FlowExtractor>::Key, <<F as SessionParserFactory<<E as FlowExtractor>::Key>>::Parser as SessionParser>::Message>>, Error>

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.