Trait WorkGraphStore 

pub trait WorkGraphStore: Send + Sync {
    // Required methods
    fn kind(&self) -> WorkGraphStoreKind;
    fn get_store_time_utc<'life0, 'async_trait>(
        &'life0 self,
    ) -> Pin<Box<dyn Future<Output = Result<DateTime<Utc>, WorkGraphError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn insert_item<'life0, 'async_trait>(
        &'life0 self,
        item: WorkItem,
        event: WorkGraphEvent,
    ) -> Pin<Box<dyn Future<Output = Result<WorkItem, WorkGraphError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn update_item_cas<'life0, 'async_trait>(
        &'life0 self,
        item: WorkItem,
        expected_previous_revision: u64,
        event: WorkGraphEvent,
    ) -> Pin<Box<dyn Future<Output = Result<WorkItem, WorkGraphError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_item<'life0, 'life1, 'life2, 'life3, 'async_trait>(
        &'life0 self,
        realm_id: &'life1 str,
        namespace: &'life2 WorkNamespace,
        id: &'life3 WorkItemId,
    ) -> Pin<Box<dyn Future<Output = Result<Option<WorkItem>, WorkGraphError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait,
             'life3: 'async_trait;
    fn list_items<'life0, 'async_trait>(
        &'life0 self,
        filter: WorkItemFilter,
    ) -> Pin<Box<dyn Future<Output = Result<Vec<WorkItem>, WorkGraphError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn insert_edge<'life0, 'async_trait>(
        &'life0 self,
        edge: WorkEdge,
        event: WorkGraphEvent,
    ) -> Pin<Box<dyn Future<Output = Result<WorkEdge, WorkGraphError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn list_edges<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self,
        realm_id: &'life1 str,
        namespace: &'life2 WorkNamespace,
    ) -> Pin<Box<dyn Future<Output = Result<Vec<WorkEdge>, WorkGraphError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait;
    fn list_events<'life0, 'async_trait>(
        &'life0 self,
        filter: WorkGraphEventFilter,
    ) -> Pin<Box<dyn Future<Output = Result<Vec<WorkGraphEvent>, WorkGraphError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}

Required Methods

fn kind(&self) -> WorkGraphStoreKind

fn get_store_time_utc<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<DateTime<Utc>, WorkGraphError>> + Send + 'async_trait>>

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

fn insert_item<'life0, 'async_trait>( &'life0 self, item: WorkItem, event: WorkGraphEvent, ) -> Pin<Box<dyn Future<Output = Result<WorkItem, WorkGraphError>> + Send + 'async_trait>>

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

fn update_item_cas<'life0, 'async_trait>( &'life0 self, item: WorkItem, expected_previous_revision: u64, event: WorkGraphEvent, ) -> Pin<Box<dyn Future<Output = Result<WorkItem, WorkGraphError>> + Send + 'async_trait>>

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

fn get_item<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, realm_id: &'life1 str, namespace: &'life2 WorkNamespace, id: &'life3 WorkItemId, ) -> Pin<Box<dyn Future<Output = Result<Option<WorkItem>, WorkGraphError>> + Send + 'async_trait>>

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

fn list_items<'life0, 'async_trait>( &'life0 self, filter: WorkItemFilter, ) -> Pin<Box<dyn Future<Output = Result<Vec<WorkItem>, WorkGraphError>> + Send + 'async_trait>>

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

fn insert_edge<'life0, 'async_trait>( &'life0 self, edge: WorkEdge, event: WorkGraphEvent, ) -> Pin<Box<dyn Future<Output = Result<WorkEdge, WorkGraphError>> + Send + 'async_trait>>

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

fn list_edges<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, realm_id: &'life1 str, namespace: &'life2 WorkNamespace, ) -> Pin<Box<dyn Future<Output = Result<Vec<WorkEdge>, WorkGraphError>> + Send + 'async_trait>>

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

fn list_events<'life0, 'async_trait>( &'life0 self, filter: WorkGraphEventFilter, ) -> Pin<Box<dyn Future<Output = Result<Vec<WorkGraphEvent>, WorkGraphError>> + Send + 'async_trait>>

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

Implementors

impl WorkGraphStore for DisabledWorkGraphStore

impl WorkGraphStore for MemoryWorkGraphStore

impl WorkGraphStore for SqliteWorkGraphStore