Struct JsonRpcSource 

pub struct JsonRpcSource { /* private fields */ }

BalSource + StateSource over plain JSON-RPC. One request per call; no batching, no retries — callers own that policy.

Implementations

impl JsonRpcSource

pub fn new(url: impl Into<String>) -> Self

Talk to the JSON-RPC endpoint at url. Requests time out after 30 s so a stalled gateway cannot hang a sync forever; redirects are not followed, so a request never silently goes to a host you did not name.

pub fn try_new(url: impl Into<String>) -> Result<Self>

Like JsonRpcSource::new but surfaces a client-construction failure.

pub async fn call(&self, method: &str, params: Value) -> Result<Value>

Raw JSON-RPC call; returns the result member or the error object as SourceError::Rpc. Transport failures (5xx from a gateway, a connection dropped mid-body) are retried a few times with backoff; RPC errors and malformed JSON are not.

pub async fn bal(&self, number: u64) -> Result<BlockAccessList>

Fetch and decode the BAL of number via eth_getBlockAccessList.

pub async fn probe(&self, old_block_age: u64) -> Result<ProbeReport>

Day-0 probe: Q1 (is the BAL served?), Q2 (for old blocks too?), and does our codec reproduce the header hash on real data.

pub async fn measure_proof_window(&self, head: u64) -> Result<u64, String>

Largest distance behind head at which eth_getProof still answers. reth: --rpc.eth-proof-window (default 0 = head only). Err if even the head is refused (no bootstrap possible at all).

Trait Implementations

impl BalSource for JsonRpcSource

fn header<'life0, 'async_trait>( &'life0 self, number: u64, ) -> Pin<Box<dyn Future<Output = Result<Header>> + Send + 'async_trait>>

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

Header only. Used for reorg checks, where fetching the BAL would be wasted work; the default goes through BalSource::block.

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

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

Latest block number the source knows.

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

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

Latest finalized block number (reorg horizon).

fn block<'life0, 'async_trait>( &'life0 self, number: u64, ) -> Pin<Box<dyn Future<Output = Result<SourcedBlock>> + Send + 'async_trait>>

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

Header + BAL for one block.

fn bal<'life0, 'async_trait>( &'life0 self, number: u64, ) -> Pin<Box<dyn Future<Output = Result<BlockAccessList>> + Send + 'async_trait>>

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

BAL body only, unverified. Lets a backup supply the body while the header — the canonical-chain fact — still comes from the primary.

impl StateSource for JsonRpcSource

fn proof<'life0, 'life1, 'async_trait>( &'life0 self, addr: Address, slots: &'life1 [B256], block: u64, ) -> Pin<Box<dyn Future<Output = Result<AccountProof>> + Send + 'async_trait>>

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

eth_getProof(addr, slots, block). One call per (address, block) carries any number of slots — batching happens here, not in JSON-RPC.