Struct SqliteTaskStore 

pub struct SqliteTaskStore { /* private fields */ }

SQLite-backed persistent TaskStore.

Open with SqliteTaskStore::open (file path) or SqliteTaskStore::open_in_memory (tests). Both return the store plus an AsyncIsleDriver the caller must shutdown().await when done — dropping the driver without a shutdown call leaves the SQLite thread as-is until the process exits.

Implementations

impl SqliteTaskStore

pub async fn open( path: impl AsRef<Path>, ) -> Result<(Self, AsyncIsleDriver), TaskStoreError>

Open (or create) a SQLite database file and run the schema migrations.

pub async fn open_in_memory() -> Result<(Self, AsyncIsleDriver), TaskStoreError>

Open an ephemeral in-memory database (tests, doctests).

Trait Implementations

impl TaskStore for SqliteTaskStore

fn name(&self) -> &str

Backend name — for diagnostics/logging.

fn create<'life0, 'async_trait>( &'life0 self, record: TaskRecord, ) -> Pin<Box<dyn Future<Output = Result<(), TaskStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Create a new Task row. Returns Duplicate if record.id is already stored.

fn get<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 TaskId, ) -> Pin<Box<dyn Future<Output = Result<TaskRecord, TaskStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Fetch a Task by id.

fn list<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<TaskRecord>, TaskStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

List every Task, newest first (descending created_at).

fn update_status<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 TaskId, status: TaskRecordStatus, ) -> Pin<Box<dyn Future<Output = Result<(), TaskStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Update a Task’s status, bumping updated_at to now.