Struct NullStateCatchup

pub struct NullStateCatchup {
    backoff: BackoffParams,
    chain_configs: HashMap<Commitment<ChainConfig>, ChainConfig>,
}

Disable catchup entirely.

Fields

backoff: BackoffParams

chain_configs: HashMap<Commitment<ChainConfig>, ChainConfig>

Implementations

impl NullStateCatchup

pub fn add_chain_config(&mut self, cf: ChainConfig)

Add a chain config preimage which can be fetched by hash during STF evaluation.

NullStateCatchup is used to disable catchup entirely when evaluating the STF, which requires the ValidatedState to be pre-seeded with all the dependencies of STF evaluation. However, the STF also depends on having the preimage of various ChainConfig commitments, which are not stored in the ValidatedState, but which instead must be supplied by a separate preimage oracle. Thus, NullStateCatchup may be populated with a set of ChainConfigs, which it can feed to the STF during evaluation.

Trait Implementations

impl Clone for NullStateCatchup

fn clone(&self) -> NullStateCatchup

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NullStateCatchup

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

Formats the value using the given formatter.

impl Default for NullStateCatchup

fn default() -> Self

Returns the “default value” for a type.

impl StateCatchup for NullStateCatchup

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, _account: &'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_fetch_reward_accounts_v2<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _retry: usize, _instance: &'life1 NodeState, _height: u64, _view: ViewNumber, _fee_merkle_tree_root: RewardMerkleCommitmentV2, _account: &'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_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_v1<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _retry: usize, _instance: &'life1 NodeState, _height: u64, _view: ViewNumber, _fee_merkle_tree_root: RewardMerkleCommitmentV1, _account: &'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 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.