Struct Flow 

pub struct Flow<T, D> {
    pub base: FlowBase<T>,
    pub data: D,
}

Fields

base: FlowBase<T>

Basic flow data organized in logical blocks.

data: D

Custom data associated with the flow.

Implementations

impl<T, D> Flow<T, D>

where T: Default + Clone + Tuple + Sized, for<'a> NetworkLayer<'a>: SourceDestLayer<T::Addr>, T::Addr: Eq, D: Default,

pub fn new( timestamp: Timestamp, tuple: T, pkt: &Packet<'_>, dir: PacketDirection, ) -> Self

Creates a new Flow instance.

pub fn packet_dir(&self, pkt: &Packet<'_>) -> PacketDirection

Determines the direction of a packet relative to the flow.

impl<T, D> Flow<T, D>

where D: Process,

pub fn process<Meta: PacketMetadata>( &mut self, meta: &Meta, pkt: &Packet<'_>, dir: PacketDirection, )

Process a packet and update flow statistics.

Trait Implementations

impl<T: Clone, D: Clone> Clone for Flow<T, D>

fn clone(&self) -> Flow<T, D>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug, D: Debug> Debug for Flow<T, D>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T: Default, D: Default> Default for Flow<T, D>

fn default() -> Flow<T, D>

Returns the “default value” for a type.

impl<'de, T, D> Deserialize<'de> for Flow<T, D>

where T: Deserialize<'de>, D: Deserialize<'de>,

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<T: PartialEq, D: PartialEq> PartialEq for Flow<T, D>

fn eq(&self, other: &Flow<T, D>) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<T, D> Serialize for Flow<T, D>

where T: Serialize, D: Serialize,

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl<T, D> Trackable for Flow<T, D>

type Timestamp = Timestamp

fn timestamp(&self) -> Timestamp

fn set_timestamp(&mut self, ts: Self::Timestamp)

impl<T: Copy, D: Copy> Copy for Flow<T, D>

impl<T: Eq, D: Eq> Eq for Flow<T, D>

impl<T, D> StructuralPartialEq for Flow<T, D>