Struct SqliteIssueStore 

pub struct SqliteIssueStore { /* private fields */ }

SQLite-backed persistent IssueStore.

Open with SqliteIssueStore::open (file path) or SqliteIssueStore::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 SqliteIssueStore

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

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

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

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

Trait Implementations

impl IssueStore for SqliteIssueStore

fn name(&self) -> &str

Backend name — for diagnostics/logging.

fn create<'life0, 'async_trait>( &'life0 self, payload: IssuePayload, ) -> Pin<Box<dyn Future<Output = Result<(), IssueStoreError>> + Send + 'async_trait>>

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

Submit a new Issue with status = Pending.

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

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

Fetch the Issue body.

fn status<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 IssueId, ) -> Pin<Box<dyn Future<Output = Result<IssueStatus, IssueStoreError>> + Send + 'async_trait>>

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

Fetch the Issue’s status; returns NotFound when absent.

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

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

List every Issue in insertion order — for audit and debug.

fn pop_pending<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Option<IssuePayload>, IssueStoreError>> + Send + 'async_trait>>

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

Pop one pending Issue (FIFO) — used by EnhancePP for dispatch. Transitions the status to InFlight on pop. Returns Ok(None) when there is no work.

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

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

Update an Issue’s status — the terminal transitions to Applied / Rejected and so on.