Struct SingleAttemptCatchup 

pub(crate) struct SingleAttemptCatchup<C> {
    inner: C,
    retry: usize,
    backoff: BackoffParams,
}

Catchup that sends each request once, for a caller that retries on its own.

The fetch_* methods of a ParallelStateCatchup race the fetch_* methods of its providers, and remote ones retry until a peer answers. Peers may never answer, for example for a height they have pruned, and then the caller waits for good. Here every fetch_* method makes one try_* call on the inner provider and returns its error.

Fields

inner: C

retry: usize

How many times the caller has tried before. It goes to the inner provider as the retry number, so that peers get longer to answer on each try, as on retries of a fetch_* call.

backoff: BackoffParams

Implementations

impl<C> SingleAttemptCatchup<C>

pub(crate) fn new(inner: C, retry: usize) -> Self

Trait Implementations

impl<C: StateCatchup> StateCatchup for SingleAttemptCatchup<C>

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 is_local(&self) -> bool

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

fn fetch_leaf<'life0, 'async_trait>( &'life0 self, coordinator: EpochMembershipCoordinator<SeqTypes>, height: u64, ) -> Pin<Box<dyn Future<Output = Result<Leaf2<SeqTypes>, Error>> + Send + 'async_trait>>

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

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

fn fetch_accounts<'life0, 'life1, 'async_trait>( &'life0 self, instance: &'life1 NodeState, height: u64, view: ViewNumber, fee_merkle_tree_root: <UniversalMerkleTree<FeeAmount, Sha3Digest, FeeAccount, espresso_types::::v0::v0_1::state::FeeMerkleTree::{constant#0}, Sha3Node> as MerkleTreeScheme>::Commitment, accounts: Vec<FeeAccount>, ) -> Pin<Box<dyn Future<Output = Result<Vec<FeeAccountProof>, Error>> + Send + 'async_trait>>

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

Fetch the given list of 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 LightWeightMerkleTree<Commitment<Header>, Sha3Digest, u64, 3, Sha3Node>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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

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

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

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

Fetch the chain config, retrying on transient errors.

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,

fn fetch_reward_accounts_v1<'life0, 'life1, 'async_trait>( &'life0 self, instance: &'life1 NodeState, height: u64, view: ViewNumber, reward_merkle_tree_root: <UniversalMerkleTree<RewardAmount, Sha3Digest, RewardAccountV1, espresso_types::::v0::v0_3::state::RewardMerkleTreeV1::{constant#0}, Sha3Node> as MerkleTreeScheme>::Commitment, accounts: Vec<RewardAccountV1>, ) -> Pin<Box<dyn Future<Output = Result<Vec<RewardAccountProofV1>, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: '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>, Error>> + Send + 'async_trait>>

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

Fetch the state certificate for a given epoch, retrying on transient errors.

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.