Struct LocalRetriever 

pub struct LocalRetriever(/* private fields */);

Durable node retriever - retrieves everything locally from storage

Implementations

impl LocalRetriever

pub fn new(collection: StorageCollectionWrapper) -> Self

pub async fn store_used_events(&mut self) -> Result<(), RetrievalError>

Trait Implementations

impl Clone for LocalRetriever

fn clone(&self) -> LocalRetriever

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl GetEvents for LocalRetriever

type Id = EventId

type Event = Event

fn retrieve_event<'life0, 'async_trait>( &'life0 self, event_ids: Vec<Self::Id>, ) -> Pin<Box<dyn Future<Output = Result<(usize, Vec<Attested<Self::Event>>), RetrievalError>> + Send + 'async_trait>>

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

retrieve the events from the store OR the remote peer

fn stage_events(&self, events: impl IntoIterator<Item = Attested<Self::Event>>)

Stage events for immediate retrieval without storage. Used when applying EventBridge deltas. Staged events are available for lineage comparison at zero budget cost before being persisted.

fn mark_event_used(&self, event_id: &Self::Id)

Mark an event as used. Used when applying EventBridge deltas.

fn estimate_cost(&self, _batch_size: usize) -> usize

Estimate the budget cost for retrieving a batch of events This allows different implementations to model their cost structure

impl Retrieve for LocalRetriever

fn get_state<'life0, 'async_trait>( &'life0 self, entity_id: EntityId, ) -> Pin<Box<dyn Future<Output = Result<Option<Attested<EntityState>>, RetrievalError>> + Send + 'async_trait>>

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