Skip to main content

WorkGraphStore

meerkat_workgraph

Trait WorkGraphStore 

Source 
pub trait WorkGraphStore: Send + Sync {

Show 27 methods    // 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 reassign_attention_cas<'life0, 'async_trait>(
        &'life0 self,
        _previous: WorkAttentionBinding,
        _expected_previous_revision: u64,
        _previous_event: WorkGraphEvent,
        _replacement: WorkAttentionBinding,
        _replacement_event: WorkGraphEvent,
    ) -> Pin<Box<dyn Future<Output = Result<(WorkAttentionBinding, 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_execution_binding<'life0, 'async_trait>(
        &'life0 self,
        _commit: WorkExecutionBindCommit,
        _expected_item_revision: u64,
        _event: WorkGraphEvent,
    ) -> Pin<Box<dyn Future<Output = Result<WorkExecutionBinding, WorkGraphError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn get_execution_binding<'life0, 'life1, 'life2, 'life3, 'async_trait>(
        &'life0 self,
        _realm_id: &'life1 str,
        _namespace: &'life2 WorkNamespace,
        _binding_id: &'life3 WorkExecutionBindingId,
    ) -> Pin<Box<dyn Future<Output = Result<Option<WorkExecutionBinding>, WorkGraphError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait,
             'life3: 'async_trait { ... }
    fn get_execution_binding_by_target_run<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self,
        _realm_id: &'life1 str,
        _run_id: &'life2 str,
    ) -> Pin<Box<dyn Future<Output = Result<Option<WorkExecutionBinding>, WorkGraphError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait { ... }
    fn update_execution_binding_cas<'life0, 'async_trait>(
        &'life0 self,
        _commit: WorkExecutionObservationCommit,
        _expected_previous_revision: u64,
        _event: WorkGraphEvent,
    ) -> Pin<Box<dyn Future<Output = Result<WorkExecutionBinding, WorkGraphError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn list_execution_bindings<'life0, 'async_trait>(
        &'life0 self,
        _filter: WorkExecutionBindingFilter,
    ) -> Pin<Box<dyn Future<Output = Result<Vec<WorkExecutionBinding>, WorkGraphError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn list_execution_bindings_for_recovery<'life0, 'life1, 'async_trait>(
        &'life0 self,
        realm_id: &'life1 str,
    ) -> Pin<Box<dyn Future<Output = Result<Vec<WorkExecutionBinding>, WorkGraphError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait { ... }
    fn list_attention_bounded<'life0, 'async_trait>(
        &'life0 self,
        filter: AttentionListRequest,
        limit: usize,
    ) -> Pin<Box<dyn Future<Output = Result<Vec<WorkAttentionBinding>, WorkGraphError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn prune_terminal_attention<'life0, 'async_trait>(
        &'life0 self,
        _filter: AttentionPruneRequest,
    ) -> Pin<Box<dyn Future<Output = Result<u64, 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 { ... }
    fn list_edges_bounded<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self,
        realm_id: &'life1 str,
        namespace: &'life2 WorkNamespace,
        limit: usize,
    ) -> 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_public_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 { ... }
    fn latest_event_seq<'life0, 'async_trait>(
        &'life0 self,
        filter: WorkGraphEventFilter,
    ) -> Pin<Box<dyn Future<Output = Result<Option<i64>, WorkGraphError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }

}

Required Methods§

Source

fn kind(&self) -> WorkGraphStoreKind

Source

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,

Source

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,

Source

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,

Source

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,

Source

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,

Source

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,

Source

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,

Source

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,

Source

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§

Source

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,

Source

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,

Source

fn reassign_attention_cas<'life0, 'async_trait>( &'life0 self, _previous: WorkAttentionBinding, _expected_previous_revision: u64, _previous_event: WorkGraphEvent, _replacement: WorkAttentionBinding, _replacement_event: WorkGraphEvent, ) -> Pin<Box<dyn Future<Output = Result<(WorkAttentionBinding, WorkAttentionBinding), WorkGraphError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Source

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,

Source

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,

Source

fn insert_execution_binding<'life0, 'async_trait>( &'life0 self, _commit: WorkExecutionBindCommit, _expected_item_revision: u64, _event: WorkGraphEvent, ) -> Pin<Box<dyn Future<Output = Result<WorkExecutionBinding, WorkGraphError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Insert one immutable execution binding after proving the referenced WorkGraph item revision and retry-chain predecessor in the same store transaction.

Source

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

Source

fn get_execution_binding_by_target_run<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _realm_id: &'life1 str, _run_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Option<WorkExecutionBinding>, WorkGraphError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Resolve the unique execution binding for one target run in a realm. This powers reverse linkage from Flow status without scanning a bounded public binding list.

Source

fn update_execution_binding_cas<'life0, 'async_trait>( &'life0 self, _commit: WorkExecutionObservationCommit, _expected_previous_revision: u64, _event: WorkGraphEvent, ) -> Pin<Box<dyn Future<Output = Result<WorkExecutionBinding, WorkGraphError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Source

fn list_execution_bindings<'life0, 'async_trait>( &'life0 self, _filter: WorkExecutionBindingFilter, ) -> Pin<Box<dyn Future<Output = Result<Vec<WorkExecutionBinding>, WorkGraphError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Source

fn list_execution_bindings_for_recovery<'life0, 'life1, 'async_trait>( &'life0 self, realm_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<WorkExecutionBinding>, WorkGraphError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Enumerate only nonterminal execution obligations for host recovery. Shipping stores override this with an active-queue projection so the hot recovery path never scans historical terminal bindings.

Source

fn list_attention_bounded<'life0, 'async_trait>( &'life0 self, filter: AttentionListRequest, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<WorkAttentionBinding>, WorkGraphError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Return at most limit attention rows. Backends should push this bound into iteration/query ownership; the default is compatibility-only for custom stores.

Source

fn prune_terminal_attention<'life0, 'async_trait>( &'life0 self, _filter: AttentionPruneRequest, ) -> Pin<Box<dyn Future<Output = Result<u64, WorkGraphError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Delete TERMINAL (superseded/stopped) attention binding rows in scope. The event stream keeps the audit history; binding rows otherwise grow monotonically with reassignment churn. Returns the pruned row count.

Source

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,

Source

fn list_edges_bounded<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, realm_id: &'life1 str, namespace: &'life2 WorkNamespace, limit: usize, ) -> 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,

Return at most limit edges in one namespace.

Source

fn list_public_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,

Return a bounded public event page while omitting internal execution lifecycle events before applying the caller’s visible limit.

Source

fn latest_event_seq<'life0, 'async_trait>( &'life0 self, filter: WorkGraphEventFilter, ) -> Pin<Box<dyn Future<Output = Result<Option<i64>, WorkGraphError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Highest sequence matching a scope without retaining the event history.

Dyn Compatibility§

This trait is dyn compatible.

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

Implementors§