Struct SubscriberResumePosition 

#[non_exhaustive]
pub struct SubscriberResumePosition {
    pub chain_id: u64,
    pub coverage_head: BlockRef,
    pub canonical_history: Vec<BlockRef>,
    pub delivery_token: Option<SubscriberDeliveryToken>,
    pub subscriber_checkpoint: Option<SubscriberCheckpoint>,
}

Durable subscriber position restored together with cache/runtime state.

The core never interprets provider checkpoint bytes. Composite and remote subscribers use this synchronous hand-off to seed their source cursors, replay fences, and canonical overlap journals before polling resumes.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

chain_id: u64

Chain whose canonical position and provider cursor are being restored.

coverage_head: BlockRef

Authoritative canonical coverage embodied by the restored cache.

canonical_history: Vec<BlockRef>

Ordered canonical identities still retained for in-window reconciliation.

delivery_token: Option<SubscriberDeliveryToken>

Last delivery token whose effects are already represented by the cache. It may still be pending at the source when the process stopped after its durable save but before the source acknowledgement committed.

subscriber_checkpoint: Option<SubscriberCheckpoint>

Provider-specific durable cursor committed with that delivery.

Implementations

impl SubscriberResumePosition

pub fn new( chain_id: u64, coverage_head: BlockRef, canonical_history: Vec<BlockRef>, delivery_token: Option<SubscriberDeliveryToken>, subscriber_checkpoint: Option<SubscriberCheckpoint>, ) -> Self

Construct a complete restored subscriber position.

Trait Implementations

impl Clone for SubscriberResumePosition

fn clone(&self) -> SubscriberResumePosition

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SubscriberResumePosition

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SubscriberResumePosition

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for SubscriberResumePosition

impl PartialEq for SubscriberResumePosition

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for SubscriberResumePosition

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for SubscriberResumePosition