Struct SqliteSessionStore 

pub struct SqliteSessionStore { /* private fields */ }

Tower-native SQLite session store that implements Load/Save services used by MemoryLayer.

Implementations

impl SqliteSessionStore

pub async fn new(db_path: impl AsRef<Path>) -> Result<Self>

Create a new file-backed store

pub async fn new_in_memory() -> Result<Self>

Create a new in-memory store (for tests)

Trait Implementations

impl Clone for SqliteSessionStore

fn clone(&self) -> SqliteSessionStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Service<LoadSession> for SqliteSessionStore

type Response = Vec<ChatCompletionRequestMessage>

Responses given by the service.

type Error = Box<dyn Error + Sync + Send>

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<SqliteSessionStore as Service<LoadSession>>::Response, <SqliteSessionStore as Service<LoadSession>>::Error>> + Send>>

The future response value.

fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, req: LoadSession) -> Self::Future

Process the request and return the response asynchronously.

impl Service<SaveSession> for SqliteSessionStore

type Response = ()

Responses given by the service.

type Error = Box<dyn Error + Sync + Send>

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<SqliteSessionStore as Service<SaveSession>>::Response, <SqliteSessionStore as Service<SaveSession>>::Error>> + Send>>

The future response value.

fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, req: SaveSession) -> Self::Future

Process the request and return the response asynchronously.