Skip to main content

IssueStore

mlua_swarm::store::issue

Trait IssueStore 

Source 
pub trait IssueStore: Send + Sync {
    // Required methods
    fn name(&self) -> &str;
    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;
    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;
    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;
    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;
    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;
    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;
}
Expand description

Persistence interface for Issues — same layer as BPStore.

Required Methods§

Source

fn name(&self) -> &str

Backend name — for diagnostics/logging.

Source

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.

Source

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.

Source

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.

Source

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.

Source

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.

Source

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.

Dyn Compatibility§

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§