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 update_item_and_attention_cas<'life0, 'async_trait>(
        &'life0 self,
        item: WorkItem,
        expected_previous_revision: u64,
        item_event: WorkGraphEvent,
        attention_updates: Vec<(WorkAttentionBinding, u64, 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;

    // Provided methods
    fn insert_goal<'life0, 'async_trait>(
        &'life0 self,
        _item: WorkItem,
        _item_event: WorkGraphEvent,
        _attention: WorkAttentionBinding,
        _attention_event: WorkGraphEvent,
    ) -> Pin<Box<dyn Future<Output = Result<(WorkItem, WorkAttentionBinding), WorkGraphError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn update_attention_cas<'life0, 'async_trait>(
        &'life0 self,
        _attention: WorkAttentionBinding,
        _expected_previous_revision: u64,
        _event: WorkGraphEvent,
    ) -> Pin<Box<dyn Future<Output = Result<WorkAttentionBinding, WorkGraphError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn get_attention<'life0, 'life1, 'life2, 'life3, 'async_trait>(
        &'life0 self,
        _realm_id: &'life1 str,
        _namespace: &'life2 WorkNamespace,
        _binding_id: &'life3 WorkAttentionBindingId,
    ) -> Pin<Box<dyn Future<Output = Result<Option<WorkAttentionBinding>, WorkGraphError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait,
             'life3: 'async_trait { ... }
    fn list_attention<'life0, 'async_trait>(
        &'life0 self,
        _filter: AttentionListRequest,
    ) -> Pin<Box<dyn Future<Output = Result<Vec<WorkAttentionBinding>, WorkGraphError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn insert_edge_validated<'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 { ... }
}

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 update_item_and_attention_cas<'life0, 'async_trait>( &'life0 self, item: WorkItem, expected_previous_revision: u64, item_event: WorkGraphEvent, attention_updates: Vec<(WorkAttentionBinding, u64, 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,

Provided Methods

fn insert_goal<'life0, 'async_trait>( &'life0 self, _item: WorkItem, _item_event: WorkGraphEvent, _attention: WorkAttentionBinding, _attention_event: WorkGraphEvent, ) -> Pin<Box<dyn Future<Output = Result<(WorkItem, WorkAttentionBinding), WorkGraphError>> + Send + 'async_trait>>

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

fn update_attention_cas<'life0, 'async_trait>( &'life0 self, _attention: WorkAttentionBinding, _expected_previous_revision: u64, _event: WorkGraphEvent, ) -> Pin<Box<dyn Future<Output = Result<WorkAttentionBinding, WorkGraphError>> + Send + 'async_trait>>

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

fn get_attention<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, _realm_id: &'life1 str, _namespace: &'life2 WorkNamespace, _binding_id: &'life3 WorkAttentionBindingId, ) -> Pin<Box<dyn Future<Output = Result<Option<WorkAttentionBinding>, WorkGraphError>> + Send + 'async_trait>>

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

fn list_attention<'life0, 'async_trait>( &'life0 self, _filter: AttentionListRequest, ) -> Pin<Box<dyn Future<Output = Result<Vec<WorkAttentionBinding>, WorkGraphError>> + Send + 'async_trait>>

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

fn insert_edge_validated<'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,

Dyn Compatibility

This trait is dyn compatible.

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

Implementors

impl WorkGraphStore for DisabledWorkGraphStore

impl WorkGraphStore for MemoryWorkGraphStore

impl WorkGraphStore for SqliteWorkGraphStore