Struct SessionState 

pub struct SessionState {

    pub id: u64,
    pub peer_addr: SocketAddr,
    pub phase: SessionPhase,
    pub connected_at: Instant,
    pub handshake_completed_at: Option<Instant>,
    pub connect_params: Option<ConnectParams>,
    pub encoder_type: EncoderType,
    pub streams: HashMap<u32, StreamState>,
    pub in_chunk_size: u32,
    pub out_chunk_size: u32,
    pub window_ack_size: u32,
    pub bytes_received: u64,
    pub bytes_sent: u64,
    pub last_ack_sequence: u32,
    /* private fields */
}

Complete session state

Fields

id: u64

Unique session ID

peer_addr: SocketAddr

Remote peer address

phase: SessionPhase

Current phase

connected_at: Instant

Connection start time

handshake_completed_at: Option<Instant>

Time when handshake completed

connect_params: Option<ConnectParams>

Connect parameters (after connect command)

encoder_type: EncoderType

Detected encoder type

streams: HashMap<u32, StreamState>

Per-stream states (keyed by message stream ID)

in_chunk_size: u32

Negotiated chunk size (incoming)

out_chunk_size: u32

Negotiated chunk size (outgoing)

window_ack_size: u32

Window acknowledgement size

bytes_received: u64

Bytes received since last acknowledgement

bytes_sent: u64

Bytes sent

last_ack_sequence: u32

Last acknowledgement sequence

Implementations

impl SessionState

pub fn new(id: u64, peer_addr: SocketAddr) -> Self

Create a new session state

pub fn start_handshake(&mut self)

Transition to handshaking phase

pub fn complete_handshake(&mut self)

Complete handshake

pub fn on_connect(&mut self, params: ConnectParams, encoder_type: EncoderType)

Handle connect command

pub fn allocate_stream_id(&mut self) -> u32

Allocate a new message stream ID

pub fn get_stream(&self, stream_id: u32) -> Option<&StreamState>

Get a stream by ID

pub fn get_stream_mut(&mut self, stream_id: u32) -> Option<&mut StreamState>

Get a mutable stream by ID

pub fn remove_stream(&mut self, stream_id: u32) -> Option<StreamState>

Remove a stream

pub fn add_bytes_received(&mut self, bytes: u64) -> bool

Update bytes received and check if acknowledgement needed

pub fn mark_ack_sent(&mut self)

Mark acknowledgement sent

pub fn duration(&self) -> Duration

Get session duration

pub fn is_active(&self) -> bool

Check if session is active

pub fn close(&mut self)

Start closing the session

pub fn app(&self) -> Option<&str>

Get the application name

Trait Implementations

impl Debug for SessionState

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

Formats the value using the given formatter.