Struct ParallelStateCatchup

pub struct ParallelStateCatchup {
    providers: Arc<Mutex<Vec<Arc<dyn StateCatchup>>>>,
}

A catchup implementation that parallelizes requests to many providers. It returns the result of the first non-erroring provider to complete.

Fields

providers: Arc<Mutex<Vec<Arc<dyn StateCatchup>>>>

Implementations

impl ParallelStateCatchup

pub fn new(providers: &[Arc<dyn StateCatchup>]) -> Self

Create a new ParallelStateCatchup with two providers.

pub fn add_provider(&self, provider: Arc<dyn StateCatchup>)

Add a provider to the list of providers

pub async fn on_local_providers<C, F, RT>(&self, closure: C) -> Result<RT>

where C: Fn(Arc<dyn StateCatchup>) -> F + Clone + Send + Sync + 'static, F: Future<Output = Result<RT>> + Send + 'static, RT: Send + Sync + 'static,

Perform an async operation on all local providers, returning the first result to succeed

pub async fn on_remote_providers<C, F, RT>(&self, closure: C) -> Result<RT>

where C: Fn(Arc<dyn StateCatchup>) -> F + Clone + Send + Sync + 'static, F: Future<Output = Result<RT>> + Send + 'static, RT: Send + Sync + 'static,

Perform an async operation on all remote providers, returning the first result to succeed

pub async fn on_providers<P, C, F, RT>( &self, predicate: P, closure: C, ) -> Result<RT>

where P: Fn(&Arc<dyn StateCatchup>) -> bool + Clone + Send + Sync + 'static, C: Fn(Arc<dyn StateCatchup>) -> F + Clone + Send + Sync + 'static, F: Future<Output = Result<RT>> + Send + 'static, RT: Send + Sync + 'static,

Perform an async operation on all providers matching the given predicate, returning the first result to succeed

Trait Implementations

impl Clone for ParallelStateCatchup

fn clone(&self) -> ParallelStateCatchup

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl StateCatchup for ParallelStateCatchup

A catchup implementation that parallelizes requests to a local and remote provider. It returns the result of the first provider to complete.

fn try_fetch_leaf<'life0, 'async_trait>( &'life0 self, retry: usize, height: u64, stake_table: HSStakeTable<SeqTypes>, success_threshold: U256, ) -> Pin<Box<dyn Future<Output = Result<Leaf2>> + Send + 'async_trait>>

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

Fetch the leaf at the given height without retrying on transient errors.

fn try_fetch_accounts<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, retry: usize, instance: &'life1 NodeState, height: u64, view: ViewNumber, fee_merkle_tree_root: FeeMerkleCommitment, accounts: &'life2 [FeeAccount], ) -> Pin<Box<dyn Future<Output = Result<Vec<FeeAccountProof>>> + Send + 'async_trait>>

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

Fetch the given list of accounts without retrying on transient errors.

fn try_remember_blocks_merkle_tree<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, retry: usize, instance: &'life1 NodeState, height: u64, view: ViewNumber, mt: &'life2 mut BlockMerkleTree, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Fetch and remember the blocks frontier without retrying on transient errors.

fn try_fetch_chain_config<'life0, 'async_trait>( &'life0 self, retry: usize, commitment: Commitment<ChainConfig>, ) -> Pin<Box<dyn Future<Output = Result<ChainConfig>> + Send + 'async_trait>>

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

Fetch the chain config without retrying on transient errors.

fn try_fetch_reward_accounts_v2<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, retry: usize, instance: &'life1 NodeState, height: u64, view: ViewNumber, reward_merkle_tree_root: RewardMerkleCommitmentV2, accounts: &'life2 [RewardAccountV2], ) -> Pin<Box<dyn Future<Output = Result<Vec<RewardAccountProofV2>>> + Send + 'async_trait>>

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

Fetch the given list of reward accounts without retrying on transient errors.

fn try_fetch_reward_accounts_v1<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, retry: usize, instance: &'life1 NodeState, height: u64, view: ViewNumber, reward_merkle_tree_root: RewardMerkleCommitmentV1, accounts: &'life2 [RewardAccountV1], ) -> Pin<Box<dyn Future<Output = Result<Vec<RewardAccountProofV1>>> + Send + 'async_trait>>

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

Fetch the given list of reward accounts without retrying on transient errors.

fn backoff(&self) -> &BackoffParams

Returns the backoff parameters for the catchup provider.

fn name(&self) -> String

Returns the name of the catchup provider.

fn fetch_accounts<'life0, 'life1, 'async_trait>( &'life0 self, instance: &'life1 NodeState, height: u64, view: ViewNumber, fee_merkle_tree_root: FeeMerkleCommitment, accounts: Vec<FeeAccount>, ) -> Pin<Box<dyn Future<Output = Result<Vec<FeeAccountProof>>> + Send + 'async_trait>>

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

Fetch the given list of accounts, retrying on transient errors.

fn fetch_leaf<'life0, 'async_trait>( &'life0 self, height: u64, stake_table: HSStakeTable<SeqTypes>, success_threshold: U256, ) -> Pin<Box<dyn Future<Output = Result<Leaf2>> + Send + 'async_trait>>

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

Fetch the leaf at the given height, retrying on transient errors.

fn fetch_chain_config<'life0, 'async_trait>( &'life0 self, commitment: Commitment<ChainConfig>, ) -> Pin<Box<dyn Future<Output = Result<ChainConfig>> + Send + 'async_trait>>

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

Fetch the chain config, retrying on transient errors.

fn fetch_reward_accounts_v2<'life0, 'life1, 'async_trait>( &'life0 self, instance: &'life1 NodeState, height: u64, view: ViewNumber, reward_merkle_tree_root: RewardMerkleCommitmentV2, accounts: Vec<RewardAccountV2>, ) -> Pin<Box<dyn Future<Output = Result<Vec<RewardAccountProofV2>>> + Send + 'async_trait>>

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

Fetch the given list of reward accounts, retrying on transient errors.

fn fetch_reward_accounts_v1<'life0, 'life1, 'async_trait>( &'life0 self, instance: &'life1 NodeState, height: u64, view: ViewNumber, reward_merkle_tree_root: RewardMerkleCommitmentV1, accounts: Vec<RewardAccountV1>, ) -> Pin<Box<dyn Future<Output = Result<Vec<RewardAccountProofV1>>> + Send + 'async_trait>>

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

Fetch the given list of reward accounts, retrying on transient errors.

fn remember_blocks_merkle_tree<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, instance: &'life1 NodeState, height: u64, view: ViewNumber, mt: &'life2 mut BlockMerkleTree, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Fetch and remember the blocks frontier, retrying on transient errors.

fn is_local(&self) -> bool

Returns true if the catchup provider is local (e.g. does not make calls to remote resources).