Struct MultiSessionStream 

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

Tagged fan-in of SessionStreams.

Implementations

impl<E, F> MultiSessionStream<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>

Human-readable label for source_idx.

pub fn alive_sources(&self) -> usize

Number of sources still being polled (haven’t returned None from their inner stream). Decrements as sources exhaust.

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

Per-source kernel ring stats. See MultiFlowStream::per_source_capture_stats.

pub fn capture_stats(&self) -> CaptureStats

Aggregate kernel ring stats. See MultiFlowStream::capture_stats.

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

Per-source tracker stats. See MultiFlowStream::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 MultiSessionStream<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,

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.