commonware_consensus::marshal::coding::shards

Enum Message

pub enum Message<B, C, H, P>where
    B: CertifiableBlock,
    C: CodingScheme,
    H: Hasher,
    P: PublicKey,{
    Proposed {
        block: CodedBlock<B, C, H>,
        round: Round,
    },
    Discovered {
        commitment: Commitment,
        leader: P,
        round: Round,
    },
    GetByCommitment {
        commitment: Commitment,
        response: Sender<Option<Arc<CodedBlock<B, C, H>>>>,
    },
    GetByDigest {
        digest: B::Digest,
        response: Sender<Option<Arc<CodedBlock<B, C, H>>>>,
    },
    SubscribeAssignedShardVerified {
        commitment: Commitment,
        response: Sender<()>,
    },
    SubscribeByCommitment {
        commitment: Commitment,
        response: Sender<Arc<CodedBlock<B, C, H>>>,
    },
    SubscribeByDigest {
        digest: B::Digest,
        response: Sender<Arc<CodedBlock<B, C, H>>>,
    },
    Prune {
        through: Commitment,
    },
}

Expand description

A message that can be sent to the coding Engine.

Variants§

§

Proposed

A request to broadcast a proposed CodedBlock to all peers.

Fields

§block: CodedBlock<B, C, H>

The erasure coded block.

§round: Round

The round in which the block was proposed.

§

Discovered

A notification from consensus that a Commitment has been discovered.

Fields

§commitment: Commitment

The Commitment of the proposed block.

§leader: P

The leader’s public key.

§round: Round

The round in which the commitment was proposed.

§

GetByCommitment

A request to get a reconstructed block, if available.

Fields

§commitment: Commitment

The Commitment of the block to get.

§response: Sender<Option<Arc<CodedBlock<B, C, H>>>>

The response channel.

§

GetByDigest

A request to get a reconstructed block by its digest, if available.

Fields

§digest: B::Digest

The digest of the block to get.

§response: Sender<Option<Arc<CodedBlock<B, C, H>>>>

The response channel.

§

SubscribeAssignedShardVerified

A request to open a subscription for assigned shard verification.

For participants, this resolves once the leader-delivered shard for the local participant index has been verified. Reconstructing the full block from gossiped shards does not resolve this subscription: that block may still be used for later certification, but it is not enough to claim the participant received the shard it is expected to echo.

For proposers, this resolves immediately after the locally built block is cached because they trivially have all shards.

Fields

§commitment: Commitment

The block’s commitment.

§response: Sender<()>

The response channel.

§

SubscribeByCommitment

A request to open a subscription for the reconstruction of a CodedBlock by its Commitment.

Fields

§commitment: Commitment

The block’s digest.

§response: Sender<Arc<CodedBlock<B, C, H>>>

The response channel.

§

SubscribeByDigest

A request to open a subscription for the reconstruction of a CodedBlock by its digest.

Fields

§digest: B::Digest

The block’s digest.

§response: Sender<Arc<CodedBlock<B, C, H>>>

The response channel.

§

Prune

A request to prune all caches at and below the given commitment.

Fields

§through: Commitment

Inclusive prune target Commitment.

Auto Trait Implementations§

§

impl<B, C, H, P> Freeze for Message<B, C, H, P>
where P: Freeze, ::Digest: Freeze, B: Freeze, <C as Scheme>::Commitment: Freeze,

§

impl<B, C, H, P> Unpin for Message<B, C, H, P>
where P: Unpin, ::Digest: Unpin, B: Unpin, <C as Scheme>::Commitment: Unpin, H: Unpin, <C as Scheme>::Shard: Unpin,

§

Message

Enum Message Copy item path

Variants§

Proposed

Fields

Discovered

Fields

GetByCommitment

Fields

GetByDigest

Fields

SubscribeAssignedShardVerified

Fields

SubscribeByCommitment

Fields

SubscribeByDigest

Fields

Prune

Fields

Auto Trait Implementations§

impl<B, C, H, P> Freeze for Message<B, C, H, P>where P: Freeze, <B as Digestible>::Digest: Freeze, B: Freeze, <C as Scheme>::Commitment: Freeze,

impl<B, C, H, P> !RefUnwindSafe for Message<B, C, H, P>

impl<B, C, H, P> Send for Message<B, C, H, P>

impl<B, C, H, P> Sync for Message<B, C, H, P>

impl<B, C, H, P> Unpin for Message<B, C, H, P>where P: Unpin, <B as Digestible>::Digest: Unpin, B: Unpin, <C as Scheme>::Commitment: Unpin, H: Unpin, <C as Scheme>::Shard: Unpin,

impl<B, C, H, P> UnsafeUnpin for Message<B, C, H, P>where P: UnsafeUnpin, <B as Digestible>::Digest: UnsafeUnpin, B: UnsafeUnpin, <C as Scheme>::Commitment: UnsafeUnpin,

impl<B, C, H, P> !UnwindSafe for Message<B, C, H, P>

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> FutureExt for T

fn with_context(self, otel_cx: Context) -> WithContext<Self>

fn with_current_context(self) -> WithContext<Self>

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self>

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>where F: FnOnce(&Self) -> bool,

impl<T> Pointable for T

const ALIGN: usize

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

impl<T> PolicyExt for Twhere T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>where T: Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>where T: Policy<B, E>, P: Policy<B, E>,

impl<T> Same for T

type Output = T

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

impl<A, B, T> HttpServerConnExec<A, B> for Twhere B: Body,

Enum Message

impl<B, C, H, P> Freeze for Message<B, C, H, P>
where P: Freeze, <B as Digestible>::Digest: Freeze, B: Freeze, <C as Scheme>::Commitment: Freeze,

impl<B, C, H, P> Unpin for Message<B, C, H, P>
where P: Unpin, <B as Digestible>::Digest: Unpin, B: Unpin, <C as Scheme>::Commitment: Unpin, H: Unpin, <C as Scheme>::Shard: Unpin,

impl<B, C, H, P> UnsafeUnpin for Message<B, C, H, P>
where P: UnsafeUnpin, <B as Digestible>::Digest: UnsafeUnpin, B: UnsafeUnpin, <C as Scheme>::Commitment: UnsafeUnpin,

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T, U> Into<U> for T
where U: From<T>,

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

impl<T> PolicyExt for T
where T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

impl<A, B, T> HttpServerConnExec<A, B> for T
where B: Body,