Struct hotshot_testing::block_builder::random::RandomBuilderSource

pub struct RandomBuilderSource<TYPES: NodeType> {
    blocks: Arc<RwLock<LruCache<BuilderCommitment, BlockEntry<TYPES>>>>,
    pub_key: TYPES::BuilderSignatureKey,
    num_nodes: Arc<RwLock<usize>>,
    should_fail_claims: Arc<AtomicBool>,
}

A mock implementation of the builder data source. Builds random blocks, doesn’t track HotShot state at all. Evicts old available blocks if HotShot doesn’t keep up.

Fields

blocks: Arc<RwLock<LruCache<BuilderCommitment, BlockEntry<TYPES>>>>

Built blocks

pub_key: TYPES::BuilderSignatureKey

num_nodes: Arc<RwLock<usize>>

should_fail_claims: Arc<AtomicBool>

Implementations

impl<TYPES> RandomBuilderSource<TYPES>

where TYPES: NodeType<Transaction = TestTransaction>, <TYPES as NodeType>::InstanceState: Default,

pub fn new( pub_key: TYPES::BuilderSignatureKey, num_nodes: Arc<RwLock<usize>>, ) -> Self

Create new RandomBuilderSource

Trait Implementations

impl<TYPES: NodeType> BuilderDataSource<TYPES> for RandomBuilderSource<TYPES>

fn available_blocks<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _for_parent: &'life1 VidCommitment, _view_number: u64, _sender: TYPES::SignatureKey, _signature: &'life2 <TYPES::SignatureKey as SignatureKey>::PureAssembledSignatureType, ) -> Pin<Box<dyn Future<Output = Result<Vec<AvailableBlockInfo<TYPES>>, BuildError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

To get the list of available blocks

fn claim_block<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, block_hash: &'life1 BuilderCommitment, _view_number: u64, _sender: TYPES::SignatureKey, _signature: &'life2 <TYPES::SignatureKey as SignatureKey>::PureAssembledSignatureType, ) -> Pin<Box<dyn Future<Output = Result<AvailableBlockData<TYPES>, BuildError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

To claim a block from the list of provided available blocks

fn claim_block_with_num_nodes<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, block_hash: &'life1 BuilderCommitment, view_number: u64, sender: TYPES::SignatureKey, signature: &'life2 <TYPES::SignatureKey as SignatureKey>::PureAssembledSignatureType, num_nodes: usize, ) -> Pin<Box<dyn Future<Output = Result<AvailableBlockData<TYPES>, BuildError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

To claim a block from the list of provided available blocks and provide the number of nodes information to the builder for VID computation.

fn claim_block_header_input<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, block_hash: &'life1 BuilderCommitment, _view_number: u64, _sender: TYPES::SignatureKey, _signature: &'life2 <TYPES::SignatureKey as SignatureKey>::PureAssembledSignatureType, ) -> Pin<Box<dyn Future<Output = Result<AvailableBlockHeaderInput<TYPES>, BuildError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

To claim a block header input

fn builder_address<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<TYPES::BuilderSignatureKey, BuildError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

To get the builder’s address

impl<TYPES: Clone + NodeType> Clone for RandomBuilderSource<TYPES>

where TYPES::BuilderSignatureKey: Clone,

fn clone(&self) -> RandomBuilderSource<TYPES>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<TYPES: Debug + NodeType> Debug for RandomBuilderSource<TYPES>

where TYPES::BuilderSignatureKey: Debug,

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

Formats the value using the given formatter.

impl<TYPES: NodeType> ReadState for RandomBuilderSource<TYPES>

type State = RandomBuilderSource<TYPES>

The type of state which this type allows a caller to read.

fn read<'life0, 'async_trait, T>( &'life0 self, op: impl 'async_trait + Send + for<'a> FnOnce(&'a Self::State) -> BoxFuture<'a, T>, ) -> Pin<Box<dyn Future<Output = T> + Send + 'async_trait>>

where T: 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

Do an operation with immutable access to the state.