Enum SubscriberRpcCause 

#[non_exhaustive]
pub enum SubscriberRpcCause {
    ChainIdentity,
    StreamSubscription,
    FlashblocksSetup,
    CanonicalHeadCertification,
    PendingStateSample,
    LogBlockVerification,
    OwnerReconcile,
    LazyBackfill,
    ReconnectBackfill,
    GapBackfill,
}

Mechanism that caused the subscriber to issue a provider request.

This is the dimension that matters for an RPC budget: a consumer asks for interests and reads batches, and every request below is a consequence the consumer never named. Attributing by cause is what makes an unexpected bill diagnosable from inside the process.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

ChainIdentity

Resolving the provider’s chain identity once, before any record escapes.

StreamSubscription

Installing a live stream source.

FlashblocksSetup

Qualifying a Flashblocks endpoint: capability probe and paired pending-state provider verification.

CanonicalHeadCertification

Certifying a sealed canonical head while Flashblocks are active, because a Flashblocks endpoint’s newHeads may carry partial heads.

PendingStateSample

Sampling OP Stack pending state on the bounded pre-confirmation cadence.

LogBlockVerification

Proving a canonical log’s block identity when SubscriberConfig::verify_log_block_context is set.

OwnerReconcile

Bulk owner catch-up requested through AlloySubscriber::reconcile_interest_owners.

LazyBackfill

Draining a queued adoption or continuity backfill.

ReconnectBackfill

Closing the window missed while a terminated stream was reconnecting.

GapBackfill

Closing the window a live stream dropped: the subscription stayed connected but notifications were lost, so only the missed range is refetched.

Implementations

impl SubscriberRpcCause

pub const ALL: [Self; 10]

Every cause the reactive stack can attribute a request to, in reporting order.

pub const COUNT: usize

Number of distinct causes.

pub const fn as_str(self) -> &'static str

Stable snake_case name, suitable for a metrics label.

Trait Implementations

impl Clone for SubscriberRpcCause

fn clone(&self) -> SubscriberRpcCause

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for SubscriberRpcCause

impl Debug for SubscriberRpcCause

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

Formats the value using the given formatter.

impl Display for SubscriberRpcCause

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

Formats the value using the given formatter.

impl Eq for SubscriberRpcCause

impl Hash for SubscriberRpcCause

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl Ord for SubscriberRpcCause

fn cmp(&self, other: &SubscriberRpcCause) -> Ordering

This method returns an Ordering between self and other.

fn max(self, other: Self) -> Self

where Self: Sized,

Compares and returns the maximum of two values.

fn min(self, other: Self) -> Self

where Self: Sized,

Compares and returns the minimum of two values.

fn clamp(self, min: Self, max: Self) -> Self

where Self: Sized,

Restrict a value to a certain interval.

fn clamp_to<R>(self, range: R) -> Self

where Self: Sized, R: ClampBounds<Self>,

🔬This is a nightly-only experimental API. (clamp_to)

Restrict a value to a certain range.

impl PartialEq for SubscriberRpcCause

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

Equality operator ==.

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

Inequality operator !=.

impl PartialOrd for SubscriberRpcCause

fn partial_cmp(&self, other: &SubscriberRpcCause) -> Option<Ordering>

This method returns an ordering between self and other values if one exists.

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

Tests less than (for self and other) and is used by the < operator.

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

Tests less than or equal to (for self and other) and is used by the <= operator.

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

Tests greater than (for self and other) and is used by the > operator.

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

Tests greater than or equal to (for self and other) and is used by the >= operator.

impl StructuralPartialEq for SubscriberRpcCause