Trait StakeTableDataSource

pub(crate) trait StakeTableDataSource<T: NodeType> {
    // Required methods
    fn get_stake_table(
        &self,
        epoch: Option<<T as NodeType>::Epoch>,
    ) -> impl Send + Future<Output = Result<Vec<PeerConfig<T>>>>;
    fn get_stake_table_current(
        &self,
    ) -> impl Send + Future<Output = Result<StakeTableWithEpochNumber<T>>>;
    fn get_validators(
        &self,
        epoch: <T as NodeType>::Epoch,
    ) -> impl Send + Future<Output = Result<IndexMap<Address, Validator<BLSPubKey>>>>;
    fn get_block_reward(
        &self,
        epoch: Option<EpochNumber>,
    ) -> impl Send + Future<Output = Result<Option<RewardAmount>>>;
    fn current_proposal_participation(
        &self,
    ) -> impl Send + Future<Output = HashMap<BLSPubKey, f64>>;
    fn previous_proposal_participation(
        &self,
    ) -> impl Send + Future<Output = HashMap<BLSPubKey, f64>>;
}

Required Methods

fn get_stake_table( &self, epoch: Option<<T as NodeType>::Epoch>, ) -> impl Send + Future<Output = Result<Vec<PeerConfig<T>>>>

Get the stake table for a given epoch

fn get_stake_table_current( &self, ) -> impl Send + Future<Output = Result<StakeTableWithEpochNumber<T>>>

Get the stake table for the current epoch if not provided

fn get_validators( &self, epoch: <T as NodeType>::Epoch, ) -> impl Send + Future<Output = Result<IndexMap<Address, Validator<BLSPubKey>>>>

Get all the validators

fn get_block_reward( &self, epoch: Option<EpochNumber>, ) -> impl Send + Future<Output = Result<Option<RewardAmount>>>

fn current_proposal_participation( &self, ) -> impl Send + Future<Output = HashMap<BLSPubKey, f64>>

Get the current proposal participation.

fn previous_proposal_participation( &self, ) -> impl Send + Future<Output = HashMap<BLSPubKey, f64>>

Get the previous proposal participation.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementations on Foreign Types

impl<N: ConnectedNetwork<PubKey>, D: Sync, V: Versions, P: SequencerPersistence> StakeTableDataSource<SeqTypes> for ExtensibleDataSource<D, ApiState<N, P, V>>

async fn get_stake_table( &self, epoch: Option<<SeqTypes as NodeType>::Epoch>, ) -> Result<Vec<PeerConfig<SeqTypes>>>

Get the stake table for a given epoch

async fn get_stake_table_current( &self, ) -> Result<StakeTableWithEpochNumber<SeqTypes>>

Get the stake table for the current epoch if not provided

async fn get_validators( &self, epoch: <SeqTypes as NodeType>::Epoch, ) -> Result<ValidatorMap>

Get all the validators

async fn current_proposal_participation(&self) -> HashMap<PubKey, f64>

Get all the validator participation for the current epoch

async fn get_block_reward( &self, epoch: Option<EpochNumber>, ) -> Result<Option<RewardAmount>>

async fn previous_proposal_participation(&self) -> HashMap<PubKey, f64>

Implementors

impl<N: ConnectedNetwork<PubKey>, V: Versions, P: SequencerPersistence> StakeTableDataSource<SeqTypes> for ApiState<N, P, V>