Struct QueryMinimizingExplorer 

pub struct QueryMinimizingExplorer<E: BlockchainExplorer> { /* private fields */ }

Wraps any BlockchainExplorer with caching and rate limiting to reduce redundant API calls to the underlying explorer.

Implementations

impl<E: BlockchainExplorer> QueryMinimizingExplorer<E>

pub fn new(inner: E, config: QueryMinimizationConfig) -> Self

Create a new QueryMinimizingExplorer wrapping inner.

pub fn query_count(&self) -> u64

Total number of queries forwarded to the inner explorer.

pub fn cache_hit_count(&self) -> u64

Total number of cache hits (queries served from cache).

pub fn cache_hit_rate(&self) -> f64

Fraction of all requests served from cache: cache_hits / (cache_hits + queries).

Returns 0.0 if no requests have been made yet.

pub fn evict_expired(&self)

Remove expired entries from both caches.

Trait Implementations

impl<E: BlockchainExplorer> BlockchainExplorer for QueryMinimizingExplorer<E>

fn get_transaction<'life0, 'life1, 'async_trait>( &'life0 self, txid: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<ExplorerTransaction, BitcoinError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Retrieve a transaction by its txid.

fn get_address_info<'life0, 'life1, 'async_trait>( &'life0 self, address: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<ExplorerAddress, BitcoinError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Retrieve address metadata and balance.

fn get_utxos<'life0, 'life1, 'async_trait>( &'life0 self, address: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<ExplorerUtxo>, BitcoinError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Retrieve the unspent outputs for an address.

fn broadcast_transaction<'life0, 'life1, 'async_trait>( &'life0 self, hex: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<String, BitcoinError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Broadcast a raw transaction (hex-encoded) to the network.

fn get_block_height<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<u32, BitcoinError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Return the current confirmed block height.