Struct FlowRecord 

pub struct FlowRecord {
    pub flow_id: String,
    pub packet_sizes: Vec<usize>,
    pub timestamps_us: Vec<u64>,
    pub directions: Vec<bool>,
    pub source_label: String,
}

A recorded traffic flow for correlation analysis.

Fields

flow_id: String

Unique flow identifier.

packet_sizes: Vec<usize>

Packet sizes in order.

timestamps_us: Vec<u64>

Timestamps in microseconds.

directions: Vec<bool>

Direction markers (true = outgoing, false = incoming).

source_label: String

Source label (for testing purposes).

Implementations

impl FlowRecord

pub fn new(flow_id: impl Into<String>) -> Self

pub fn add_packet(&mut self, size: usize, timestamp_us: u64, outgoing: bool)

Add a packet to this flow.

pub fn duration_us(&self) -> u64

Duration of the flow in microseconds.

pub fn total_bytes(&self) -> usize

Total bytes transferred.

pub fn inter_packet_delays(&self) -> Vec<u64>

Inter-packet delays in microseconds.

pub fn avg_packet_size(&self) -> f64

Average packet size.

pub fn packet_count(&self) -> usize

Packet count.

Trait Implementations

impl Clone for FlowRecord

fn clone(&self) -> FlowRecord

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FlowRecord

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for FlowRecord

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for FlowRecord

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

where __S: Serializer,

Serialize this value into the given Serde serializer.