Struct MultiChainReader 

pub struct MultiChainReader {
    pub providers: HashMap<ChainId, Arc<dyn ChainProvider>>,
}

Executes storage reads and contract calls across many chains in parallel.

Example

use std::sync::Arc;
use std::collections::HashMap;
use xenith_core::ChainId;
use xenith_read::MultiChainReader;

let reader = MultiChainReader::new(HashMap::new());
let results = reader.read_parallel(vec![ChainId::from(1)], [0u8; 20], [0u8; 32]).await;

Fields

providers: HashMap<ChainId, Arc<dyn ChainProvider>>

Implementations

impl MultiChainReader

pub fn new(providers: HashMap<ChainId, Arc<dyn ChainProvider>>) -> Self

pub async fn read_parallel( &self, chains: Vec<ChainId>, address: [u8; 20], slot: [u8; 32], ) -> Result<Vec<(ChainId, [u8; 32])>>

Read slot from address on every chain in chains, concurrently.

Tasks are spawned for all chains simultaneously. Failures are logged as warnings and omitted from the returned Vec; only successful readings are included. The outer Result only fails if something prevents spawning (which in practice never happens with tokio).

pub async fn call_parallel( &self, chains: Vec<ChainId>, address: [u8; 20], calldata: Bytes, ) -> Result<Vec<(ChainId, Bytes)>>

Call address with calldata on every chain in chains, concurrently.

Same failure-tolerance semantics as read_parallel.

pub async fn check_divergence( &self, chains: Vec<ChainId>, address: [u8; 20], slot: [u8; 32], ) -> Result<DivergenceReport>

Read slot across chains and report whether their values agree.