Struct EventService 

pub struct EventService<S, H>
where
    S: EventStore,
    H: EventHandler,
{ /* private fields */ }

Service for managing domain events with DTO conversion Uses compile-time polymorphism for zero-cost abstractions

Implementations

impl<S, H> EventService<S, H>

where S: EventStore, H: EventHandler,

pub fn new(event_store: Arc<Mutex<S>>, event_handler: H) -> Self

Create new event service with event store and handler

pub async fn publish_event(&self, event: DomainEvent) -> ApplicationResult<()>

Publish domain event with zero-cost handling

pub async fn publish_events( &self, events: Vec<DomainEvent>, ) -> ApplicationResult<()>

Publish multiple domain events

pub fn get_session_events_dto( &self, session_id: SessionId, ) -> ApplicationResult<Vec<DomainEventDto>>

Get events for session as DTOs (for API responses)

pub fn get_stream_events_dto( &self, stream_id: StreamId, ) -> ApplicationResult<Vec<DomainEventDto>>

Get events for stream as DTOs (for API responses)

pub fn get_events_since_dto( &self, since: DateTime<Utc>, ) -> ApplicationResult<Vec<DomainEventDto>>

Get events since timestamp as DTOs (for API responses)

pub fn get_session_events( &self, session_id: SessionId, ) -> ApplicationResult<Vec<DomainEvent>>

Get events for session (domain objects, for internal use)

pub fn get_stream_events( &self, stream_id: StreamId, ) -> ApplicationResult<Vec<DomainEvent>>

Get events for stream (domain objects, for internal use)

pub fn replay_from_dtos( &self, event_dtos: Vec<DomainEventDto>, ) -> ApplicationResult<Vec<DomainEvent>>

Replay events from DTOs (for event sourcing reconstruction)

impl<S> EventService<S, NoOpEventHandler>

where S: EventStore,

Convenience constructors for common configurations

pub fn with_noop_handler(event_store: Arc<Mutex<S>>) -> Self

Create event service with no-op handler (maximum performance)

impl<S> EventService<S, LoggingEventHandler>

where S: EventStore,

pub fn with_logging_handler(event_store: Arc<Mutex<S>>) -> Self

Create event service with logging handler (zero-allocation logging)

impl<S, H> EventService<S, H>

where S: EventStore, H: EventHandler,

Event publishing convenience methods

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

Publish session activated event

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

Publish session closed event

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

Publish stream created event

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

Publish stream completed event

pub async fn publish_stream_failed( &self, session_id: SessionId, stream_id: StreamId, error: String, ) -> ApplicationResult<()>

Publish stream failed event