Trait RuntimeMessageStore 

pub trait RuntimeMessageStore:
    MessageRetriever
    + Send
    + Sync {
    // Required methods
    fn add_input_message<'life0, 'async_trait>(
        &'life0 self,
        session_id: SessionId,
        input: InputMessage,
    ) -> Pin<Box<dyn Future<Output = Result<Message>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn store_message<'life0, 'async_trait>(
        &'life0 self,
        session_id: SessionId,
        message: Message,
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}

👎Deprecated since 0.17.25:

execution is event-authoritative; use everruns_host::EventLog and EventHistory

Legacy writable message-store contract retained only for 0.17 source paths.

It is not accepted by RuntimeBackends and is never used by execution. Canonical events are the only maintained write path; this shim is scheduled for deletion in 0.18.

Required Methods

fn add_input_message<'life0, 'async_trait>( &'life0 self, session_id: SessionId, input: InputMessage, ) -> Pin<Box<dyn Future<Output = Result<Message>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

👎Deprecated since 0.17.25:

execution is event-authoritative; use everruns_host::EventLog and EventHistory

Legacy, non-authoritative input-message write.

fn store_message<'life0, 'async_trait>( &'life0 self, session_id: SessionId, message: Message, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

👎Deprecated since 0.17.25:

execution is event-authoritative; use everruns_host::EventLog and EventHistory

Legacy, non-authoritative message write.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementations on Foreign Types

impl RuntimeMessageStore for InMemoryMessageRetriever

fn add_input_message<'life0, 'async_trait>( &'life0 self, session_id: SessionId, input: InputMessage, ) -> Pin<Box<dyn Future<Output = Result<Message>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

👎Deprecated since 0.17.25:

execution is event-authoritative; use everruns_host::EventLog and EventHistory

fn store_message<'life0, 'async_trait>( &'life0 self, session_id: SessionId, message: Message, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

👎Deprecated since 0.17.25:

execution is event-authoritative; use everruns_host::EventLog and EventHistory

Implementors