Struct Coding 

pub struct Coding<B, C, H, P>(/* private fields */)
where
    B: CertifiableBlock<Context = Context<Commitment<B, C, H>, P>> + Codec,
    C: CodingScheme,
    H: Hasher,
    P: PublicKey;

The coding variant of Marshal, which uses erasure coding for block dissemination.

This variant distributes blocks as erasure-coded shards, allowing reconstruction from a subset of shards. This reduces bandwidth requirements for block propagation.

Trait Implementations

impl<B, C, H, P> Buffer<Coding<B, C, H, P>> for Mailbox<B, C, H, P>

where B: CertifiableBlock<Context = Context<Commitment<B, C, H>, P>> + Codec, C: CodingScheme, H: Hasher, P: PublicKey,

type PublicKey = P

The public key type used to identify peers.

async fn find_by_digest( &self, digest: <CodedBlock<B, C, H> as Digestible>::Digest, ) -> Option<Arc<CodedBlock<B, C, H>>>

Attempt to find a block by its digest.

async fn find_by_commitment( &self, commitment: Commitment<B, C, H>, ) -> Option<Arc<CodedBlock<B, C, H>>>

Attempt to find a block by its commitment.

fn subscribe_by_digest( &self, digest: <CodedBlock<B, C, H> as Digestible>::Digest, ) -> Option<Receiver<Arc<CodedBlock<B, C, H>>>>

Subscribe to a block’s availability by its digest.

fn subscribe_by_commitment( &self, commitment: Commitment<B, C, H>, ) -> Option<Receiver<Arc<CodedBlock<B, C, H>>>>

Subscribe to a block’s availability by its commitment.

fn send( &self, round: Round, block: Arc<CodedBlock<B, C, H>>, _recipients: Recipients<P>, )

Send a block to peers.

impl<B, C, H, P> Clone for Coding<B, C, H, P>

where B: CertifiableBlock<Context = Context<Commitment<B, C, H>, P>> + Codec, C: CodingScheme, H: Hasher, P: PublicKey,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<B, C, H, P> Copy for Coding<B, C, H, P>

where B: CertifiableBlock<Context = Context<Commitment<B, C, H>, P>> + Codec, C: CodingScheme, H: Hasher, P: PublicKey,

impl<B, C, H, P> Default for Coding<B, C, H, P>

where B: CertifiableBlock<Context = Context<Commitment<B, C, H>, P>> + Codec + Default, C: CodingScheme + Default, H: Hasher + Default, P: PublicKey + Default,

fn default() -> Self

Returns the “default value” for a type.

impl<B, C, H, P> Variant for Coding<B, C, H, P>

where B: CertifiableBlock<Context = Context<Commitment<B, C, H>, P>> + Codec, C: CodingScheme, H: Hasher, P: PublicKey,

fn max_buffer_payload_size(participants: u32, application: usize) -> usize

Returns an upper bound on the encoded size of any shard a committee of 4 to participants members codes from a block of at most application bytes.

Panics

Panics if participants is below 4 or above u16::MAX.

type ApplicationBlock = B

The application block type, as decoded from the wire.

type Block = Arc<CodedBlock<B, C, H>>

The working block type of marshal, whose digest and consensus commitment are ready.

type StoredBlock = StoredCodedBlock<B, C, H>

The type of block stored in the archive, as decoded from storage.

type Commitment = Commitment<B, C, H>

The Digest type used by consensus.

fn commitment(block: &Self::Block) -> Self::Commitment

Returns the consensus commitment of a block.

fn commitment_to_inner( commitment: Self::Commitment, ) -> <Self::Block as Digestible>::Digest

Extracts the block digest from a consensus commitment.

fn parent_commitment(block: &Self::Block) -> Self::Commitment

Returns the parent commitment referenced by block.

fn stored_parent_commitment(block: &Self::StoredBlock) -> Self::Commitment

Returns the parent commitment referenced by a stored block.

fn check_payload<S>(scheme: &S, payload: Self::Commitment) -> bool

where S: SimplexScheme<Self::Commitment>,

Validates a certificate payload against the active consensus scheme.

fn decode_block( buf: impl Input, block_cfg: &<Self::ApplicationBlock as Read>::Cfg, expected: ExpectedCommitment<Self::Commitment>, strategy: &impl Strategy, ) -> impl Future<Output = Result<Self::Block, CodecError>> + Send

Decodes a Self::Block received over the wire, failing unless Self::commitment of the result equals the commitment in expected.

fn restore( stored: Self::StoredBlock, digest: <Self::Block as Digestible>::Digest, ) -> Self::Block

Restores a working block from its stored form and digest, the key it was stored under.

fn restore_across( stored: Self::StoredBlock, _strategy: &impl Strategy, ) -> impl Future<Output = Self::Block> + Send

Restores a working block from its stored form when the key it was stored under is unknown, computing any identity the stored form lacks as a job on strategy.

fn into_shared(block: Self::Block) -> Digested<Self::ApplicationBlock>

Converts a working block to the application block without copying the payload.

fn from_application_block( block: Digested<Self::ApplicationBlock>, payload: Self::Commitment, ) -> Self::Block

Reconstructs a working block from an application block and the trusted consensus payload that commits to it.

fn max_backfill_block_size(application: usize) -> usize

Returns the largest encoded size of a Self::Block a backfill response carries for an application block of at most application encoded bytes.