Struct KvStore 

pub struct KvStore { /* private fields */ }

Wrapper around Cloudflare KV for conversation storage

Implementations

impl KvStore

pub fn new(kv: WorkerKvStore) -> Self

Create a new KV store wrapper

pub fn with_ttl(self, ttl_seconds: u64) -> Self

Set custom TTL for conversation entries

pub async fn get_conversation( &self, session_id: &str, ) -> Result<Vec<Message>, CloudflareError>

Get conversation history for a session

pub async fn save_conversation( &self, session_id: &str, messages: &[Message], ) -> Result<(), CloudflareError>

Save conversation history for a session

pub async fn append_message( &self, session_id: &str, message: Message, ) -> Result<(), CloudflareError>

Append a message to conversation history

pub async fn clear_conversation( &self, session_id: &str, ) -> Result<(), CloudflareError>

Clear conversation history for a session

pub async fn get_metadata( &self, session_id: &str, ) -> Result<Option<SessionMetadata>, CloudflareError>

Get session metadata

pub async fn save_metadata( &self, session_id: &str, metadata: &SessionMetadata, ) -> Result<(), CloudflareError>

Save session metadata