Struct WebSocketStreamSession 

pub struct WebSocketStreamSession {
    pub id: String,
    pub created_at: Instant,
    pub options: StreamOptions,
    pub plan: Vec<StreamFrame>,
    pub current_frame: u32,
    pub acknowledged_frames: Vec<u32>,
    pub client_metrics: ClientMetrics,
    pub rate_limit_guard: Option<RateLimitGuard>,
    /* private fields */
}

WebSocket streaming session state.

This type is intentionally distinct from the domain-layer crate::domain::aggregates::StreamSession aggregate. The WebSocket transport maintains an ephemeral, transport-local session model with raw String identifiers and an in-memory HashMap keyed off AdaptiveStreamController; it does not share state with the StreamRepositoryGat-backed domain session created by POST /pjs/sessions. Sessions created over WebSocket cannot be addressed over HTTP and vice versa, and dictionary training, auth, and rate-limit middleware applied to the HTTP router do not apply to this controller.

See issue #239 for the full rationale and the deliberate split between the two session models.

Fields

id: String

Transport-local session identifier.

created_at: Instant

Instant the session was created.

options: StreamOptions

Streaming options negotiated for this session.

plan: Vec<StreamFrame>

Pre-computed delivery plan as an ordered list of frames.

current_frame: u32

Index of the next frame to send.

acknowledged_frames: Vec<u32>

Frame indices acknowledged by the client so far.

client_metrics: ClientMetrics

Adaptive streaming metrics derived from client acks.

rate_limit_guard: Option<RateLimitGuard>

Rate-limit guard scoped to this session, if installed.

Trait Implementations

impl Debug for WebSocketStreamSession

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

Formats the value using the given formatter.