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;
}

Message store contract for runtime persistence and lookup.

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,

Store a new input message and return the generated message record.

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,

Persist an existing message record.

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,

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,

Implementors