Struct StatePeers 

pub struct StatePeers<ApiVer: StaticVersionType> {
    scores: Arc<RwLock<PriorityQueue<usize, PeerScore>>>,
    clients: Vec<Client<ServerError, ApiVer>>,
    backoff: BackoffParams,
}

Fields

scores: Arc<RwLock<PriorityQueue<usize, PeerScore>>>

clients: Vec<Client<ServerError, ApiVer>>

backoff: BackoffParams

Implementations

impl<ApiVer: StaticVersionType> StatePeers<ApiVer>

async fn fetch<Fut>( &self, retry: usize, f: impl Fn(Client<ServerError, ApiVer>) -> Fut, ) -> Result<Fut::Ok>

where Fut: TryFuture<Error: Display>,

pub fn from_urls( urls: Vec<Url>, backoff: BackoffParams, metrics: &(impl Metrics + ?Sized), ) -> Self

pub async fn fetch_config( &self, my_own_validator_config: ValidatorConfig<SeqTypes>, ) -> Result<NetworkConfig<SeqTypes>>

Trait Implementations

impl<ApiVer: Clone + StaticVersionType> Clone for StatePeers<ApiVer>

fn clone(&self) -> StatePeers<ApiVer>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<ApiVer: Debug + StaticVersionType> Debug for StatePeers<ApiVer>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<ApiVer: Default + StaticVersionType> Default for StatePeers<ApiVer>

fn default() -> StatePeers<ApiVer>

Returns the “default value” for a type.

impl<ApiVer: StaticVersionType> StateCatchup for StatePeers<ApiVer>

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_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_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 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, height: u64, stake_table: HSStakeTable<SeqTypes>, success_threshold: Uint<256, 4>, ) -> 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_accounts_v2<'life0, 'life1, 'async_trait>( &'life0 self, instance: &'life1 NodeState, height: u64, view: ViewNumber, reward_merkle_tree_root: <UniversalMerkleTree<RewardAmount, Keccak256Hasher, RewardAccountV2, espresso_types::::v0::v0_4::state::RewardMerkleTreeV2::{constant#0}, KeccakNode> as MerkleTreeScheme>::Commitment, accounts: Vec<RewardAccountV2>, ) -> Pin<Box<dyn Future<Output = Result<Vec<RewardAccountProofV2>, 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_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.