Struct EventHistory 

pub struct EventHistory { /* private fields */ }

Read-only message/history projection rebuilt from canonical events.

Implementations

impl EventHistory

pub fn new(reader: Arc<dyn EventReader>) -> EventHistory

Project messages from a bounded canonical event reader.

pub fn event_reader(&self) -> Arc<dyn EventReader>

Underlying canonical reader.

pub async fn has_history( &self, session_id: TypedId<SessionIdMarker>, ) -> Result<bool, EventLogError>

Whether the canonical log contains any event for this session id.

This reports history presence only. It is deliberately not a session identity/catalog check: a valid session can have no events, and retained events can outlive the session record that originally produced them.

pub async fn read_page( &self, request: EventHistoryReadRequest, ) -> Result<EventHistoryPage, EventLogError>

Read one bounded projected-message page without collecting the session.

Raw event reads stay bounded by the remaining message slots, lifecycle envelopes are skipped, the first event snapshot is retained across all internal reads, and no more than MAX_EVENT_HISTORY_REPLAY envelopes are examined.

Trait Implementations

impl Clone for EventHistory

fn clone(&self) -> EventHistory

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl MessageRetriever for EventHistory

fn get<'life0, 'async_trait>( &'life0 self, session_id: TypedId<SessionIdMarker>, message_id: TypedId<MessageIdMarker>, ) -> Pin<Box<dyn Future<Output = Result<Option<Message>, AgentLoopError>> + Send + 'async_trait>>

where 'life0: 'async_trait, EventHistory: 'async_trait,

Get a specific message by ID

fn load<'life0, 'async_trait>( &'life0 self, session_id: TypedId<SessionIdMarker>, ) -> Pin<Box<dyn Future<Output = Result<Vec<Message>, AgentLoopError>> + Send + 'async_trait>>

where 'life0: 'async_trait, EventHistory: 'async_trait,

Load all messages for a session

fn load_filtered<'life0, 'async_trait>( &'life0 self, query: MessageQuery, ) -> Pin<Box<dyn Future<Output = Result<Vec<Message>, AgentLoopError>> + Send + 'async_trait>>

where 'life0: 'async_trait, EventHistory: 'async_trait,

Load messages with filters and injections applied.

fn load_filtered_history<'life0, 'async_trait>( &'life0 self, query: MessageQuery, ) -> Pin<Box<dyn Future<Output = Result<MessageHistory, AgentLoopError>> + Send + 'async_trait>>

where 'life0: 'async_trait, EventHistory: 'async_trait,

fn load_page<'life0, 'async_trait>( &'life0 self, session_id: TypedId<SessionIdMarker>, offset: usize, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<Message>, AgentLoopError>> + Send + 'async_trait>>

where 'life0: 'async_trait, EventHistory: 'async_trait,

Load messages with pagination

fn count<'life0, 'async_trait>( &'life0 self, session_id: TypedId<SessionIdMarker>, ) -> Pin<Box<dyn Future<Output = Result<usize, AgentLoopError>> + Send + 'async_trait>>

where 'life0: 'async_trait, EventHistory: 'async_trait,

Count messages in a session