Struct ConversationState 

pub struct ConversationState {
    pub key: CanonicalKey,
    pub status: ConversationStatus,
    pub start_time: Duration,
    pub last_seen: Duration,
    pub forward: DirectionStats,
    pub reverse: DirectionStats,
    pub packet_indices: Vec<usize>,
    pub protocol_state: ProtocolState,
    pub max_flow_len: Option<u64>,
}

Complete state for a single bidirectional conversation.

Tracks the canonical key, timing, per-direction statistics, packet indices (into the original capture), and protocol-specific state (TCP state machine or UDP timeout tracking).

Fields

key: CanonicalKey

Canonical bidirectional key identifying this conversation.

status: ConversationStatus

Current conversation status.

start_time: Duration

Timestamp of the first packet in the conversation.

last_seen: Duration

Timestamp of the most recent packet in the conversation.

forward: DirectionStats

Statistics for the forward direction (addr_a → addr_b).

reverse: DirectionStats

Statistics for the reverse direction (addr_b → addr_a).

packet_indices: Vec<usize>

Indices of packets belonging to this conversation (into original packet list).

protocol_state: ProtocolState

Protocol-specific state.

max_flow_len: Option<u64>

Maximum packet length across both directions (if tracking enabled).

Implementations

impl ConversationState

pub fn new(key: CanonicalKey, timestamp: Duration) -> Self

Create a new conversation state from the first observed packet.

pub fn new_zwave(zwave_key: ZWaveKey, timestamp: Duration) -> Self

Create a new Z-Wave conversation state.

Z-Wave conversations use a dummy canonical key since they are keyed by home ID and node pair rather than IP 5-tuple.

pub fn total_packets(&self) -> u64

Total packets across both directions.

pub fn total_bytes(&self) -> u64

Total bytes across both directions.

pub fn duration(&self) -> Duration

Duration of the conversation.

pub fn record_packet( &mut self, direction: FlowDirection, byte_count: u64, timestamp: Duration, packet_index: usize, track_max_packet_len: bool, track_max_flow_len: bool, store_packet_indices: bool, )

Record a packet in this conversation.

pub fn update_status(&mut self)

Update the conversation status based on protocol state.

pub fn is_timed_out(&self, now: Duration, config: &FlowConfig) -> bool

Check whether this conversation has exceeded its idle timeout.

Trait Implementations

impl Debug for ConversationState

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

Formats the value using the given formatter.