Struct SubscriberBackfill 

pub struct SubscriberBackfill { /* private fields */ }

Historical log backfill requested when adding subscriber interests.

Backfill applies only to ReactiveInterest::Logs entries. Block and pending-transaction interests are live-only. AlloySubscriber emits records fetched through this policy as InputSource::Backfill. Continuity-safe owner registration adopts/subscribes the desired live filter first, then reconciles history behind that live fence; startup/global replacement commits topology and historical work as one desired-state transaction. A drained backfill seeds the filter’s delivery anchor at its resolved upper bound (even when the window held no logs), so the newly added filter gets the same reconnect/catch-up protection an established one has.

Implementations

impl SubscriberBackfill

pub fn range(from_block: u64, to_block: u64) -> Self

Backfill an inclusive block range.

pub fn from_block(from_block: u64) -> Self

Backfill from from_block through the provider’s latest block.

pub fn from_canonical_block(block: BlockRef) -> Self

Backfill inclusively from an exact retained canonical block.

The Alloy subscriber verifies this number/hash against its provider before accepting any lazy catch-up response. Engine-managed mid-stream registration uses this form so owner replay cannot silently cross a reorged discovery boundary.

pub fn from_canonical_block_through( block: BlockRef, to_block: u64, ) -> Result<Self, SubscriberError>

Backfill inclusively from an exact canonical block through an inclusive upper bound.

Errors

Returns SubscriberError::InvalidConfig when to_block precedes the retained anchor.

pub fn after_canonical_block(block: BlockRef) -> Result<Self, SubscriberError>

Backfill strictly after an exact canonical state baseline.

This is distinct from from_canonical_block: a restored cache already embodies every effect through block, so replaying that block would apply it twice. The retained block is still carried so the subscriber can prove that its provider is on the same canonical branch before accepting any post-baseline history.

Returns an error at u64::MAX; silently saturating would turn an empty exclusive range into an inclusive replay of the baseline block.

Errors

Returns SubscriberError::InvalidConfig when the baseline number is u64::MAX and therefore has no following block.

pub fn after_canonical_block_through( block: BlockRef, to_block: u64, ) -> Result<Self, SubscriberError>

Backfill strictly after an exact canonical baseline through an inclusive upper bound.

to_block == block.number represents a deliberately empty certified interval. Bounds before the retained baseline are rejected.

Errors

Returns SubscriberError::InvalidConfig when to_block precedes the baseline, or when a non-empty exclusive range would have to begin after block u64::MAX.

pub fn start_block(&self) -> u64

First block included in the backfill.

pub fn end_block(&self) -> Option<u64>

Last block included in the backfill, or None for provider latest.

pub fn retained_anchor(&self) -> Option<&BlockRef>

Exact retained start-block identity, when supplied.

Trait Implementations

impl Clone for SubscriberBackfill

fn clone(&self) -> SubscriberBackfill

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for SubscriberBackfill

impl Debug for SubscriberBackfill

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Eq for SubscriberBackfill

impl PartialEq for SubscriberBackfill

fn eq(&self, other: &SubscriberBackfill) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for SubscriberBackfill