Struct StakeTableFetcher

pub struct StakeTableFetcher {
    pub(crate) peers: Arc<dyn StateCatchup>,
    pub(crate) persistence: Arc<Mutex<dyn MembershipPersistence>>,
    pub(crate) l1_client: L1Client,
    pub(crate) chain_config: Arc<Mutex<ChainConfig>>,
    pub(crate) update_task: Arc<StakeTableUpdateTask>,
}

Fields

peers: Arc<dyn StateCatchup>

Peers for catching up the stake table

persistence: Arc<Mutex<dyn MembershipPersistence>>

Methods for stake table persistence.

l1_client: L1Client

L1 provider

chain_config: Arc<Mutex<ChainConfig>>

Verifiable ChainConfig holding contract address

update_task: Arc<StakeTableUpdateTask>

Implementations

impl StakeTableFetcher

pub fn new( peers: Arc<dyn StateCatchup>, persistence: Arc<Mutex<dyn MembershipPersistence>>, l1_client: L1Client, chain_config: ChainConfig, ) -> Self

pub async fn spawn_update_loop(&self)

fn update_loop(&self) -> impl Future<Output = ()>

Periodically updates the stake table from the L1 contract. This function polls the finalized block number from the L1 client at an interval and fetches stake table from contract and updates the persistence

pub async fn fetch_events( &self, contract: Address, to_block: u64, ) -> Result<Vec<(EventKey, StakeTableEvent)>>

pub async fn fetch_events_from_contract( l1_client: L1Client, contract: Address, from_block: Option<u64>, to_block: u64, ) -> Result<StakeTableEvents>

Fetch all stake table events from L1

pub async fn fetch_and_store_stake_table_events( &self, contract: Address, to_block: u64, ) -> Result<Vec<(EventKey, StakeTableEvent)>>

Get StakeTable at specific l1 block height. This function fetches and processes various events (ValidatorRegistered, ValidatorExit, Delegated, Undelegated, and ConsensusKeysUpdated) within the block range from the contract’s initialization block to the provided to_block value. Events are fetched in chunks to and retries are implemented for failed requests.

pub async fn fetch_all_validators( l1_client: L1Client, contract: Address, to_block: u64, ) -> Result<IndexMap<Address, Validator<BLSPubKey>>>

pub async fn fetch( &self, epoch: <SeqTypes as NodeType>::Epoch, header: Header, ) -> Option<IndexMap<Address, Validator<BLSPubKey>>>

pub(crate) async fn get_chain_config( &self, header: &Header, ) -> Result<ChainConfig>

Retrieve and verify ChainConfig

Trait Implementations

impl Clone for StakeTableFetcher

fn clone(&self) -> StakeTableFetcher

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for StakeTableFetcher

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

Formats the value using the given formatter.