Struct DisabledWorkGraphStore 

pub struct DisabledWorkGraphStore;

Trait Implementations

impl Default for DisabledWorkGraphStore

fn default() -> DisabledWorkGraphStore

Returns the “default value” for a type.

impl WorkGraphStore for DisabledWorkGraphStore

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_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<'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 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<'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,

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 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.

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,

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.

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,

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.

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.

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.

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.

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.

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.