Struct StrictMembership 

pub struct StrictMembership<T, S>
where
    T: NodeType,
    S: TestStakeTable<T::SignatureKey, T::StateSignatureKey>,
{
    inner: Arc<RwLock<Inner<T, S>>>,
    epoch_height: BlockNumber,
}

Fields

inner: Arc<RwLock<Inner<T, S>>>

epoch_height: BlockNumber

Trait Implementations

impl<T, S> Clone for StrictMembership<T, S>

where T: NodeType + Clone, S: TestStakeTable<T::SignatureKey, T::StateSignatureKey> + Clone,

fn clone(&self) -> StrictMembership<T, S>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T, S> Debug for StrictMembership<T, S>

where T: NodeType, S: TestStakeTable<T::SignatureKey, T::StateSignatureKey>,

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

Formats the value using the given formatter.

impl<T, S> Membership<T> for StrictMembership<T, S>

where T: NodeType, S: TestStakeTable<T::SignatureKey, T::StateSignatureKey>,

type Error = StrictMembershipError

type Snapshot = StrictEpochSnapshot<T, S>

A consistent per-epoch view, returned by Self::snapshot.

type NonEpochSnapshot = StrictNonEpochSnapshot<T, S>

A consistent pre-epoch view, returned by Self::non_epoch_snapshot.

fn snapshot(&self, epoch: EpochNumber) -> Option<Self::Snapshot>

Capture a consistent per-epoch view.

fn non_epoch_snapshot(&self) -> Self::NonEpochSnapshot

Capture a consistent pre-epoch view.

fn add_drb_result(&self, e: EpochNumber, drb: DrbResult)

Called to notify the Membership when a new DRB result has been calculated.

fn first_epoch(&self) -> Option<EpochNumber>

Get first epoch if epochs are enabled, None otherwise.

fn set_first_epoch(&self, e: EpochNumber, 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(&self, hdr: T::BlockHeader) -> Result<(), Self::Error>

Handles notifications that a new epoch root has been created.

async fn get_epoch_root(&self, e: EpochNumber) -> Result<Leaf2<T>, Self::Error>

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

async fn get_epoch_drb(&self, e: EpochNumber) -> Result<DrbResult, Self::Error>

Gets the DRB result for the given epoch.

fn add_da_committee( &self, first_epoch: EpochNumber, committee: Vec<PeerConfig<T>>, )

Register a DA committee that takes effect starting at first_epoch.

fn highest_known_epoch(&self) -> Option<EpochNumber>

Get the highest epoch for which a stake table is currently in memory, or None if no stake tables are loaded. Used at startup to find the point from which to walk forward catching up missing epochs.

impl<T, S> TestableMembership<T> for StrictMembership<T, S>

where T: NodeType, S: TestStakeTable<T::SignatureKey, T::StateSignatureKey>,

fn new( quorum_members: Vec<PeerConfig<T>>, da_members: Vec<PeerConfig<T>>, _public_key: T::SignatureKey, epoch_height: u64, ) -> Self

Construct a membership for tests.

fn set_leaf_fetcher( &self, network: Arc<dyn LeafFetcherNetwork<T>>, storage: TestStorage<T>, public_key: T::SignatureKey, channel: Receiver<Event<T>>, )

Install a fully wired leaf fetcher. Must be called before any code path that triggers catchup (get_epoch_root / get_epoch_drb).