Struct ParallelStateCatchup 

pub struct ParallelStateCatchup {
    providers: Arc<Mutex<Vec<Provider>>>,
    backoff: BackoffParams,
    local_timeout: Duration,
    fallback_delay: Duration,
}

A catchup implementation that races all providers. It returns the first successful result.

Fields

providers: Arc<Mutex<Vec<Provider>>>

backoff: BackoffParams

local_timeout: Duration

Timeout for local provider requests

fallback_delay: Duration

Implementations

impl ParallelStateCatchup

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

Create a new ParallelStateCatchup with the given providers and local timeout.

pub fn with_fallback_delay(self, delay: Duration) -> Self

Delay before fallback providers start; see Provider::fallback.

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

Add a provider to the list of providers

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

Add a remote provider that races after the fallback delay; see Provider::fallback.

fn add(&self, catchup: Arc<dyn StateCatchup>, fallback: bool)

async fn on_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 providers, 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

fn try_fetch_leaf<'life0, 'async_trait>( &'life0 self, retry: usize, coordinator: EpochMembershipCoordinator<SeqTypes>, height: u64, ) -> 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_merkle_tree_v2<'life0, 'async_trait>( &'life0 self, retry: usize, height: u64, view: ViewNumber, reward_merkle_tree_root: RewardMerkleCommitmentV2, accounts: Arc<Vec<RewardAccountV2>>, ) -> Pin<Box<dyn Future<Output = Result<PermittedRewardMerkleTreeV2>> + Send + 'async_trait>>

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

Fetch the given reward merkle tree 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 try_fetch_state_cert<'life0, 'async_trait>( &'life0 self, retry: usize, epoch: u64, ) -> Pin<Box<dyn Future<Output = Result<LightClientStateUpdateCertificateV2<SeqTypes>>> + Send + 'async_trait>>

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

Fetch the state certificate for a given epoch 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, coordinator: EpochMembershipCoordinator<SeqTypes>, height: u64, ) -> 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_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 fetch_state_cert<'life0, 'async_trait>( &'life0 self, epoch: u64, ) -> Pin<Box<dyn Future<Output = Result<LightClientStateUpdateCertificateV2<SeqTypes>>> + Send + 'async_trait>>

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

Fetch the state certificate for a given epoch, 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).

fn with_local_timeout( &self, local_timeout: Duration, ) -> Option<Arc<dyn StateCatchup>>

A copy of this provider that waits up to local_timeout on its local providers, or None if it has no such timeout.

fn fetch_reward_merkle_tree_v2<'life0, 'async_trait>( &'life0 self, height: u64, view: ViewNumber, reward_merkle_tree_root: MerkleTreeCommitment<KeccakNode>, accounts: Arc<Vec<RewardAccountV2>>, ) -> Pin<Box<dyn Future<Output = Result<PermittedRewardMerkleTreeV2, Error>> + Send + 'async_trait>>

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