Struct StreamSession 

pub struct StreamSession { /* private fields */ }

StreamSession aggregate root - manages multiple prioritized streams

Implementations

impl StreamSession

pub fn new(config: SessionConfig) -> Self

Create new session

pub fn id(&self) -> SessionId

Get session ID

pub fn state(&self) -> &SessionState

Get current state

pub fn config(&self) -> &SessionConfig

Get configuration

pub fn stats(&self) -> &SessionStats

Get statistics

pub fn created_at(&self) -> DateTime<Utc>

Get creation timestamp

pub fn updated_at(&self) -> DateTime<Utc>

Get last update timestamp

pub fn expires_at(&self) -> DateTime<Utc>

Get expiration timestamp

pub fn completed_at(&self) -> Option<DateTime<Utc>>

Get completion timestamp

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

Get client info metadata

pub fn duration(&self) -> Option<Duration>

Get session duration if completed

pub fn is_expired(&self) -> bool

Check if session is expired

pub fn is_active(&self) -> bool

Check if session is active

pub fn streams(&self) -> &HashMap<StreamId, Stream>

Get all streams

pub fn get_stream(&self, stream_id: StreamId) -> Option<&Stream>

Get stream by ID

pub fn update_stream_config( &mut self, stream_id: StreamId, config: StreamConfig, ) -> DomainResult<()>

Update configuration of a child stream through the aggregate root.

Child mutations must flow through the aggregate so the session-level timestamp is bumped and a DomainEvent::StreamConfigUpdated event is raised. Application code MUST NOT reach into Stream directly to mutate config — the previous get_stream_mut accessor that allowed this was a DDD violation (see issue #259).

pub fn create_stream_patch_frames( &mut self, stream_id: StreamId, priority_threshold: Priority, max_frames: usize, ) -> DomainResult<Vec<Frame>>

Generate patch frames for a child stream through the aggregate root.

Wraps Stream::create_patch_frames so that session-level statistics (stats.total_frames) and the updated_at timestamp stay consistent with the child mutation, and a DomainEvent::FramesBatched event is raised when frames are produced.

pub fn activate(&mut self) -> DomainResult<()>

Activate session

pub fn create_stream(&mut self, source_data: JsonData) -> DomainResult<StreamId>

Create new stream in this session

pub fn start_stream(&mut self, stream_id: StreamId) -> DomainResult<()>

Start streaming for a specific stream

pub fn complete_stream(&mut self, stream_id: StreamId) -> DomainResult<()>

Complete a specific stream

pub fn fail_stream( &mut self, stream_id: StreamId, error: String, ) -> DomainResult<()>

Fail a specific stream

pub fn create_priority_frames( &mut self, batch_size: usize, ) -> DomainResult<Vec<Frame>>

Create frames for all active streams based on priority

pub fn close(&mut self) -> DomainResult<()>

Close session gracefully

pub fn force_close_expired(&mut self) -> DomainResult<bool>

Force close expired session with proper cleanup

pub fn extend_timeout(&mut self, additional_seconds: u64) -> DomainResult<()>

Extend session timeout (if allowed)

pub fn set_client_info( &mut self, client_info: String, user_agent: Option<String>, ip_address: Option<String>, )

Set client information

pub fn pending_events(&self) -> &VecDeque<DomainEvent>

Get pending domain events

pub fn take_events(&mut self) -> VecDeque<DomainEvent>

Take all pending events (clears the queue)

pub fn health_check(&self) -> SessionHealth

Check session health

Trait Implementations

impl Clone for StreamSession

fn clone(&self) -> StreamSession

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamSession

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for StreamSession

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for StreamSession

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

where __S: Serializer,

Serialize this value into the given Serde serializer.