Struct SessionService

pub struct SessionService<CH, QH>
where
    CH: CommandHandler<CreateSessionCommand, SessionId> + CommandHandler<CreateStreamCommand, StreamId> + CommandHandler<StartStreamCommand, ()> + CommandHandler<CompleteStreamCommand, ()> + CommandHandler<CloseSessionCommand, ()>,
    QH: QueryHandler<GetSessionQuery, SessionResponse> + QueryHandler<GetSessionHealthQuery, HealthResponse> + QueryHandler<GetActiveSessionsQuery, SessionsResponse>,
{ /* private fields */ }

High-level service for session management workflows

Implementations

impl<CH, QH> SessionService<CH, QH>

where CH: CommandHandler<CreateSessionCommand, SessionId> + CommandHandler<CreateStreamCommand, StreamId> + CommandHandler<StartStreamCommand, ()> + CommandHandler<CompleteStreamCommand, ()> + CommandHandler<CloseSessionCommand, ()> + Send + Sync, QH: QueryHandler<GetSessionQuery, SessionResponse> + QueryHandler<GetSessionHealthQuery, HealthResponse> + QueryHandler<GetActiveSessionsQuery, SessionsResponse> + Send + Sync,

pub fn new(command_handler: Arc<CH>, query_handler: Arc<QH>) -> Self

pub async fn create_and_activate_session( &self, config: SessionConfig, client_info: Option<String>, user_agent: Option<String>, ip_address: Option<String>, ) -> ApplicationResult<SessionId>

Create new session with automatic activation

pub async fn create_and_start_stream( &self, session_id: SessionId, source_data: Value, config: Option<StreamConfig>, ) -> ApplicationResult<StreamId>

Create stream and immediately start it

pub async fn get_session_with_health( &self, session_id: SessionId, ) -> ApplicationResult<SessionWithHealth>

Get session with health check

pub async fn complete_stream_and_maybe_close_session( &self, session_id: SessionId, stream_id: StreamId, ) -> ApplicationResult<SessionCompletionResult>

Complete stream and close session if no more active streams

pub async fn get_sessions_overview( &self, limit: Option<usize>, ) -> ApplicationResult<SessionsOverview>

Get overview of all active sessions

pub async fn graceful_shutdown_session( &self, session_id: SessionId, ) -> ApplicationResult<SessionShutdownResult>

Gracefully shutdown session with all streams

Trait Implementations

impl<CH, QH> Debug for SessionService<CH, QH>

where CH: CommandHandler<CreateSessionCommand, SessionId> + CommandHandler<CreateStreamCommand, StreamId> + CommandHandler<StartStreamCommand, ()> + CommandHandler<CompleteStreamCommand, ()> + CommandHandler<CloseSessionCommand, ()> + Debug, QH: QueryHandler<GetSessionQuery, SessionResponse> + QueryHandler<GetSessionHealthQuery, HealthResponse> + QueryHandler<GetActiveSessionsQuery, SessionsResponse> + Debug,

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

Formats the value using the given formatter.