Struct EventPipeline 

pub struct EventPipeline { /* private fields */ }

Orchestrates decoding, applying, reorg handling, and reconciliation of a block’s logs against an EvmCache.

Construct one from a DecoderRegistry, then call ingest_logs per block. See the module docs for the freshness-wiring pattern (event-derived slots → Pinned, reconciled periodically).

Implementations

impl EventPipeline

pub fn new(registry: DecoderRegistry) -> Self

Create a pipeline over registry with the default ReorgConfig.

pub fn with_reorg_config(self, cfg: ReorgConfig) -> Self

Override the ReorgConfig (reorg horizon depth + purge scope).

pub fn ingest_logs( &mut self, cache: &mut EvmCache, block: u64, logs: &[Log], ) -> BlockDigest

Decode + apply a block’s logs, log-by-log in order, recording touched state for reorg tracking. Returns the per-block BlockDigest.

Each log is decoded against the current cache state and applied immediately, so a later log’s decode observes the effects of earlier logs in the same block through the StateView (e.g. a same-block Burn after a Mint, or two overlapping Mints). The touched addresses are recorded in the depth-bounded reorg ring under block, and the touched (address, slot) pairs into the parallel depth-bounded reconcile-sampling ring.

pub fn reorg_to(&mut self, cache: &mut EvmCache, new_head: u64) -> StateDiff

Reorg to new_head: purge (per ReorgConfig::scope) every address touched in a block > new_head, drop those ring entries, and return the merged purge StateDiff.

The next read of a purged address re-fetches from RPC. The caller then re-ingests the canonical chain’s logs for the reorged range (and/or the next read lazily re-fetches).

pub fn reconcile( &mut self, cache: &mut EvmCache, slots: &[(Address, U256)], ) -> Result<ReconcileReport>

Sampled reconciliation: re-read slots via EvmCache::verify_slots (correct + alarm). Returns the mismatches.

It fetches the fresh chain value for each slot, injects the ones that changed (so the cache is corrected), and returns the changed set — a non-empty ReconcileReport::mismatched is the drift alarm: event-derived state had drifted and has now been corrected to chain truth. Honest about reachability (via EvmCache::reconcile_slots): it errors when no batch fetcher is configured or when a non-empty request could not fetch any slot (a total fetch failure is not a silent all-clear). An empty slots is a no-op that returns an empty report.

pub fn derived_slots(&self) -> impl Iterator<Item = (Address, U256)> + '_

All event-derived slots retained within the reorg horizon (the sampling source for reconcile).

Flattens the block-horizon ring and dedupes, so each (address, slot) pair is yielded exactly once even if it was touched in more than one retained block (set semantics preserved).