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 error if conversation not found or 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.

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.