Struct SubscriberRpcStats 

pub struct SubscriberRpcStats { /* private fields */ }

Every provider request the reactive stack has issued, by method and by the mechanism responsible for it.

Counts are cumulative for the subscriber’s lifetime. They deliberately survive reconnects, stream-topology changes, and delivery-state resets, so a long-running process can report total RPC consumption; call AlloySubscriber::reset_rpc_stats to measure a bounded window instead. This is the difference from FlashblocksRpcMetrics, which is scoped to one Flashblocks subscriber generation and resets with it.

Every request the subscriber makes is counted here, including the ones also tallied by FlashblocksRpcMetrics — reading both never requires adding them together. FlashblocksRpcMetrics remains the place for outcomes that are not request counts, such as receipts that were unavailable or samples discarded for racing the pending block.

let stats = subscriber.rpc_stats();
println!("total provider requests: {}", stats.total());
println!("eth_getLogs: {}", stats.by_method(SubscriberRpcMethod::EthGetLogs));
for (cause, method, requests) in stats.nonzero() {
    println!("{cause} / {method}: {requests}");
}

Implementations

impl SubscriberRpcStats

pub const fn get( &self, cause: SubscriberRpcCause, method: SubscriberRpcMethod, ) -> u64

Requests issued for one exact cause/method pair.

pub fn by_cause(&self, cause: SubscriberRpcCause) -> u64

Requests issued for one cause, across every method.

pub fn by_method(&self, method: SubscriberRpcMethod) -> u64

Requests issued for one method, across every cause.

pub fn total(&self) -> u64

Every provider request the subscriber has issued.

pub fn entries( &self, ) -> impl Iterator<Item = (SubscriberRpcCause, SubscriberRpcMethod, u64)> + '_

Every cause/method pair in reporting order, including zeroes.

pub fn nonzero( &self, ) -> impl Iterator<Item = (SubscriberRpcCause, SubscriberRpcMethod, u64)> + '_

Only the cause/method pairs that actually issued a request — the useful shape for logging or a metrics export.

Trait Implementations

impl Clone for SubscriberRpcStats

fn clone(&self) -> SubscriberRpcStats

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SubscriberRpcStats

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

Formats the value using the given formatter.

impl Default for SubscriberRpcStats

fn default() -> Self

Returns the “default value” for a type.

impl Eq for SubscriberRpcStats

impl PartialEq for SubscriberRpcStats

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for SubscriberRpcStats