Struct FactIndex 

pub struct FactIndex { /* private fields */ }

In-memory index of durable FactKey -> ArtifactId bindings.

The engine rebuilds this index from prior domain events before executing a run.

Implementations

impl FactIndex

pub fn from_event_stream(stream: &[EventEnvelope]) -> Self

Rebuilds the durable fact bindings recorded in an event stream.

Only the first durable binding for a given key is kept, matching the single-assignment contract used by live/replay IO.

pub async fn get(&self, key: &FactKey) -> Option<ArtifactId>

Returns the currently bound payload id for key, if one exists.

pub async fn bind_if_unset( &self, key: FactKey, payload_id: ArtifactId, ) -> (ArtifactId, bool)

Binds key to payload_id only if the key is not already bound.

Returns the effective payload id together with a flag indicating whether a new binding was inserted.

pub async fn unbind_if_matches( &self, key: &FactKey, payload_id: &ArtifactId, ) -> bool

Removes the binding for key only when it still points to payload_id.

This is used to roll back optimistic in-memory bindings when durable recording fails.

Trait Implementations

impl Clone for FactIndex

fn clone(&self) -> FactIndex

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for FactIndex

fn default() -> FactIndex

Returns the “default value” for a type.