Struct StrictMembership 

pub struct StrictMembership<TYPES: NodeType, StakeTable: TestStakeTable<TYPES::SignatureKey, TYPES::StateSignatureKey>> {
    inner: StakeTable,
    epochs: HashSet<TYPES::Epoch>,
    drbs: HashSet<TYPES::Epoch>,
    fetcher: Arc<RwLock<Leaf2Fetcher<TYPES>>>,
    epoch_height: u64,
}

Fields

inner: StakeTable

epochs: HashSet<TYPES::Epoch>

drbs: HashSet<TYPES::Epoch>

fetcher: Arc<RwLock<Leaf2Fetcher<TYPES>>>

epoch_height: u64

Implementations

impl<TYPES: NodeType, StakeTable: TestStakeTable<TYPES::SignatureKey, TYPES::StateSignatureKey>> StrictMembership<TYPES, StakeTable>

fn assert_has_stake_table(&self, epoch: Option<TYPES::Epoch>)

fn assert_has_randomized_stake_table(&self, epoch: Option<TYPES::Epoch>)

Trait Implementations

impl<TYPES: Clone + NodeType, StakeTable: Clone + TestStakeTable<TYPES::SignatureKey, TYPES::StateSignatureKey>> Clone for StrictMembership<TYPES, StakeTable>

where TYPES::Epoch: Clone,

fn clone(&self) -> StrictMembership<TYPES, StakeTable>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<TYPES, StakeTable> Debug for StrictMembership<TYPES, StakeTable>

where TYPES: NodeType, StakeTable: TestStakeTable<TYPES::SignatureKey, TYPES::StateSignatureKey>,

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

Formats the value using the given formatter.

impl<TYPES: NodeType, StakeTable: TestStakeTable<TYPES::SignatureKey, TYPES::StateSignatureKey>> Membership<TYPES> for StrictMembership<TYPES, StakeTable>

fn has_stake( &self, pub_key: &<TYPES as NodeType>::SignatureKey, epoch: Option<<TYPES as NodeType>::Epoch>, ) -> bool

Check if a node has stake in the committee

fn has_da_stake( &self, pub_key: &<TYPES as NodeType>::SignatureKey, epoch: Option<<TYPES as NodeType>::Epoch>, ) -> bool

Check if a node has stake in the da committee

type Error = Error

The error type returned by methods like lookup_leader.

type StakeTableHash = NoStakeTableHash

type Storage = TestStorage<TYPES>

Storage type used by the underlying fetcher

fn new<I: NodeImplementation<TYPES>>( quorum_members: Vec<PeerConfig<TYPES>>, da_members: Vec<PeerConfig<TYPES>>, storage: Self::Storage, network: Arc<<I as NodeImplementation<TYPES>>::Network>, public_key: TYPES::SignatureKey, epoch_height: u64, ) -> Self

Create a committee

async fn set_external_channel( &mut self, external_channel: Receiver<Event<TYPES>>, )

fn stake_table(&self, epoch: Option<TYPES::Epoch>) -> HSStakeTable<TYPES>

Get all participants in the committee (including their stake) for a specific epoch

fn da_stake_table(&self, epoch: Option<TYPES::Epoch>) -> HSStakeTable<TYPES>

Get all participants in the committee (including their stake) for a specific epoch

fn committee_members( &self, _view_number: TYPES::View, epoch: Option<TYPES::Epoch>, ) -> BTreeSet<TYPES::SignatureKey>

Get all participants in the committee for a specific view for a specific epoch

fn da_committee_members( &self, _view_number: TYPES::View, epoch: Option<TYPES::Epoch>, ) -> BTreeSet<TYPES::SignatureKey>

Get all participants in the committee for a specific view for a specific epoch

fn stake( &self, pub_key: &TYPES::SignatureKey, epoch: Option<TYPES::Epoch>, ) -> Option<PeerConfig<TYPES>>

Get the stake table entry for a public key, returns None if the key is not in the table for a specific epoch

fn da_stake( &self, pub_key: &TYPES::SignatureKey, epoch: Option<TYPES::Epoch>, ) -> Option<PeerConfig<TYPES>>

Get the DA stake table entry for a public key, returns None if the key is not in the table for a specific epoch

fn lookup_leader( &self, view: TYPES::View, epoch: Option<TYPES::Epoch>, ) -> Result<TYPES::SignatureKey>

The leader of the committee for view view_number in epoch.

fn total_nodes(&self, epoch: Option<TYPES::Epoch>) -> usize

Returns the number of total nodes in the committee in an epoch epoch

fn da_total_nodes(&self, epoch: Option<TYPES::Epoch>) -> usize

Returns the number of total DA nodes in the committee in an epoch epoch

fn has_stake_table(&self, epoch: TYPES::Epoch) -> bool

Returns if the stake table is available for the given epoch

fn has_randomized_stake_table(&self, epoch: TYPES::Epoch) -> Result<bool>

Returns if the randomized stake table is available for the given epoch

fn add_drb_result(&mut self, epoch: TYPES::Epoch, drb_result: DrbResult)

Called to notify the Membership when a new DRB result has been calculated. Observes the same semantics as add_epoch_root

fn first_epoch(&self) -> Option<TYPES::Epoch>

Get first epoch if epochs are enabled, None otherwise

fn set_first_epoch( &mut self, epoch: TYPES::Epoch, initial_drb_result: DrbResult, )

Called to notify the Membership that Epochs are enabled. Implementations should copy the pre-epoch stake table into epoch and epoch+1 when this is called. The value of initial_drb_result should be used for DRB calculations for epochs (epoch+1) and earlier.

async fn add_epoch_root( membership: Arc<RwLock<Self>>, block_header: TYPES::BlockHeader, ) -> Result<()>

Handles notifications that a new epoch root has been created.

async fn get_epoch_root( membership: Arc<RwLock<Self>>, epoch: TYPES::Epoch, ) -> Result<Leaf2<TYPES>>

Gets the validated block header and epoch number of the epoch root at the given block height

async fn get_epoch_drb( membership: Arc<RwLock<Self>>, epoch: TYPES::Epoch, ) -> Result<DrbResult>

Gets the DRB result for the given epoch

fn add_da_committee( &mut self, first_epoch: u64, committee: Vec<PeerConfig<TYPES>>, )

fn total_stake(&self, epoch: Option<<TYPES as NodeType>::Epoch>) -> Uint<256, 4>

fn total_da_stake( &self, epoch: Option<<TYPES as NodeType>::Epoch>, ) -> Uint<256, 4>

fn leader( &self, view: <TYPES as NodeType>::View, epoch: Option<<TYPES as NodeType>::Epoch>, ) -> Result<<TYPES as NodeType>::SignatureKey, Error>

The leader of the committee for view view_number in epoch.

fn success_threshold( &self, epoch: Option<<TYPES as NodeType>::Epoch>, ) -> Uint<256, 4>

Returns the threshold for a specific Membership implementation

fn da_success_threshold( &self, epoch: Option<<TYPES as NodeType>::Epoch>, ) -> Uint<256, 4>

Returns the DA threshold for a specific Membership implementation

fn failure_threshold( &self, epoch: Option<<TYPES as NodeType>::Epoch>, ) -> Uint<256, 4>

Returns the threshold for a specific Membership implementation

fn upgrade_threshold( &self, epoch: Option<<TYPES as NodeType>::Epoch>, ) -> Uint<256, 4>

Returns the threshold required to upgrade the network protocol

fn stake_table_hash( &self, _epoch: <TYPES as NodeType>::Epoch, ) -> Option<Commitment<Self::StakeTableHash>>

Returns the commitment of the stake table for the given epoch, Errors if the stake table is not available for the given epoch