Struct ConversationStore 

pub struct ConversationStore { /* private fields */ }

Conversation storage operations.

Implementations

impl ConversationStore

pub fn disabled() -> Self

Creates a disabled conversation store.

pub fn new(pool: Arc<DbPool>) -> Self

Creates a new conversation store with database pool.

pub async fn create(&self) -> StoreResult<ConversationData>

Creates a new conversation.

Errors

Returns error if database query fails.

pub async fn get_or_create( &self, conversation_id: &str, ) -> StoreResult<ConversationData>

Gets a conversation or creates it if it doesn’t exist.

Errors

Returns error if database query fails.

pub async fn get(&self, conversation_id: &str) -> StoreResult<ConversationData>

Gets a conversation by ID.

Errors

Returns error if conversation not found or database query fails.

pub async fn rehydrate( &self, conversation_id: &str, ) -> StoreResult<Vec<InOutItem>>

Rehydrates a conversation with all its items.

Errors

Returns an error if a stored item is missing its sequence number or if the database query fails.

pub async fn rehydrate_snapshot( &self, conversation_id: &str, ) -> StoreResult<ConversationSnapshot>

Rehydrates a conversation with its items and storage version.

Errors

Returns an error if a stored item is missing its sequence number or if the database query fails.

pub async fn persist( &self, conversation_id: &str, response_id: &str, previous_response_id: Option<&str>, new_items: Vec<InOutItem>, metadata: &ResponseMetadata, ) -> StoreResult<()>

Persists conversation turn with new items and response metadata.

Creates items in the conversation and stores the associated response record.

Errors

Returns StorageError if conversation not found or database operation fails.

pub async fn persist_if_version( &self, conversation_id: &str, expected_version: ConversationVersion, response_id: &str, previous_response_id: Option<&str>, new_items: Vec<InOutItem>, metadata: &ResponseMetadata, ) -> StoreResult<()>

Persists a conversation turn only if its stored version still matches.

Errors

Returns StorageError if the conversation changed, was not found, or a database operation fails.

Trait Implementations

impl Clone for ConversationStore

fn clone(&self) -> ConversationStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConversationStore

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

Formats the value using the given formatter.