Enum polkadot_node_subsystem::messages::NetworkBridgeTxMessage

source ·

pub enum NetworkBridgeTxMessage {
    ReportPeer(ReportPeerMessage),
    DisconnectPeer(PeerId, PeerSet),
    SendValidationMessage(Vec<PeerId>, Versioned<ValidationProtocol, ValidationProtocol, ValidationProtocol>),
    SendCollationMessage(Vec<PeerId>, Versioned<CollationProtocol, CollationProtocol>),
    SendValidationMessages(Vec<(Vec<PeerId>, Versioned<ValidationProtocol, ValidationProtocol, ValidationProtocol>)>),
    SendCollationMessages(Vec<(Vec<PeerId>, Versioned<CollationProtocol, CollationProtocol>)>),
    SendRequests(Vec<Requests>, IfDisconnected),
    ConnectToValidators {
        validator_ids: Vec<Public>,
        peer_set: PeerSet,
        failed: Sender<usize>,
    },
    ConnectToResolvedValidators {
        validator_addrs: Vec<HashSet<Multiaddr>>,
        peer_set: PeerSet,
    },
    AddToResolvedValidators {
        validator_addrs: Vec<HashSet<Multiaddr>>,
        peer_set: PeerSet,
    },
}

Expand description

Messages received from other subsystems by the network bridge subsystem.

Variants§

§

ReportPeer(ReportPeerMessage)

Report a peer for their actions.

§

DisconnectPeer(PeerId, PeerSet)

Disconnect a peer from the given peer-set without affecting their reputation.

§

SendValidationMessage(Vec<PeerId>, Versioned<ValidationProtocol, ValidationProtocol, ValidationProtocol>)

Send a message to one or more peers on the validation peer-set.

§

SendCollationMessage(Vec<PeerId>, Versioned<CollationProtocol, CollationProtocol>)

Send a message to one or more peers on the collation peer-set.

§

SendValidationMessages(Vec<(Vec<PeerId>, Versioned<ValidationProtocol, ValidationProtocol, ValidationProtocol>)>)

Send a batch of validation messages.

NOTE: Messages will be processed in order (at least statement distribution relies on this).

§

SendCollationMessages(Vec<(Vec<PeerId>, Versioned<CollationProtocol, CollationProtocol>)>)

Send a batch of collation messages.

NOTE: Messages will be processed in order.

§

SendRequests(Vec<Requests>, IfDisconnected)

Send requests via substrate request/response. Second parameter, tells what to do if we are not yet connected to the peer.

§

ConnectToValidators

Connect to peers who represent the given validator_ids.

Also ask the network to stay connected to these peers at least until a new request is issued.

Because it overrides the previous request, it must be ensured that validator_ids include all peers the subsystems are interested in (per PeerSet).

A caller can learn about validator connections by listening to the PeerConnected events from the network bridge.

Fields

§validator_ids: Vec<Public>

Ids of the validators to connect to.

§peer_set: PeerSet

The underlying protocol to use for this request.

§failed: Sender<usize>

Sends back the number of AuthorityDiscoveryIds which authority discovery has failed to resolve.

§

ConnectToResolvedValidators

Alternative to ConnectToValidators in case you already know the Multiaddrs you want to be connected to.

Fields

§validator_addrs: Vec<HashSet<Multiaddr>>

Each entry corresponds to the addresses of an already resolved validator.

§peer_set: PeerSet

The peer set we want the connection on.

§

AddToResolvedValidators

Extends the known validators set with new peers we already know the Multiaddrs, this is usually needed for validators that change their address mid-session. It is usually called after a ConnectToResolvedValidators at the beginning of the session.

Fields

§validator_addrs: Vec<HashSet<Multiaddr>>

Each entry corresponds to the addresses of an already resolved validator.

§peer_set: PeerSet

The peer set we want the connection on.

Trait Implementations§

§

impl AssociateOutgoing for NetworkBridgeTxMessage

§

type OutgoingMessages = NetworkBridgeTxOutgoingMessages

The associated outgoing messages for a subsystem that consumes the message Self.

Enum polkadot_node_subsystem::messages::NetworkBridgeTxMessageCopy item path

Variants§

ReportPeer(ReportPeerMessage)

DisconnectPeer(PeerId, PeerSet)

SendValidationMessage(Vec<PeerId>, Versioned<ValidationProtocol, ValidationProtocol, ValidationProtocol>)

SendCollationMessage(Vec<PeerId>, Versioned<CollationProtocol, CollationProtocol>)

SendValidationMessages(Vec<(Vec<PeerId>, Versioned<ValidationProtocol, ValidationProtocol, ValidationProtocol>)>)

SendCollationMessages(Vec<(Vec<PeerId>, Versioned<CollationProtocol, CollationProtocol>)>)

SendRequests(Vec<Requests>, IfDisconnected)

ConnectToValidators

Fields

ConnectToResolvedValidators

Fields

AddToResolvedValidators

Fields

Trait Implementations§

impl AssociateOutgoing for NetworkBridgeTxMessage

type OutgoingMessages = NetworkBridgeTxOutgoingMessages

impl Debug for NetworkBridgeTxMessage

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

impl From<NetworkBridgeTxMessage> for AllMessages

fn from(message: NetworkBridgeTxMessage) -> AllMessages

impl From<NetworkBridgeTxMessage> for ApprovalDistributionOutgoingMessages

fn from(message: NetworkBridgeTxMessage) -> ApprovalDistributionOutgoingMessages

impl From<NetworkBridgeTxMessage> for ApprovalVotingParallelOutgoingMessages

fn from( message: NetworkBridgeTxMessage, ) -> ApprovalVotingParallelOutgoingMessages

impl From<NetworkBridgeTxMessage> for AvailabilityDistributionOutgoingMessages

fn from( message: NetworkBridgeTxMessage, ) -> AvailabilityDistributionOutgoingMessages

impl From<NetworkBridgeTxMessage> for AvailabilityRecoveryOutgoingMessages

fn from(message: NetworkBridgeTxMessage) -> AvailabilityRecoveryOutgoingMessages

impl From<NetworkBridgeTxMessage> for BitfieldDistributionOutgoingMessages

fn from(message: NetworkBridgeTxMessage) -> BitfieldDistributionOutgoingMessages

impl From<NetworkBridgeTxMessage> for CollatorProtocolOutgoingMessages

fn from(message: NetworkBridgeTxMessage) -> CollatorProtocolOutgoingMessages

impl From<NetworkBridgeTxMessage> for DisputeDistributionOutgoingMessages

fn from(message: NetworkBridgeTxMessage) -> DisputeDistributionOutgoingMessages

impl From<NetworkBridgeTxMessage> for GossipSupportOutgoingMessages

fn from(message: NetworkBridgeTxMessage) -> GossipSupportOutgoingMessages

impl From<NetworkBridgeTxMessage> for StatementDistributionOutgoingMessages

fn from( message: NetworkBridgeTxMessage, ) -> StatementDistributionOutgoingMessages

impl TryFrom<AllMessages> for NetworkBridgeTxMessage

type Error = ()

fn try_from( message: AllMessages, ) -> Result<NetworkBridgeTxMessage, <NetworkBridgeTxMessage as TryFrom<AllMessages>>::Error>

Auto Trait Implementations§

impl Freeze for NetworkBridgeTxMessage

impl !RefUnwindSafe for NetworkBridgeTxMessage

impl Send for NetworkBridgeTxMessage

impl Sync for NetworkBridgeTxMessage

impl Unpin for NetworkBridgeTxMessage

impl !UnwindSafe for NetworkBridgeTxMessage

Blanket Implementations§

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

fn type_id(&self) -> TypeId

impl<T> Any for Twhere T: Any,

fn into_any(self: Box<T>) -> Box<dyn Any>

fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>

fn type_name(&self) -> &'static str

impl<T> AnySync for Twhere T: Any + Send + Sync,

fn into_any_arc(self: Arc<T>) -> Arc<dyn Any + Send + Sync>

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> CheckedConversion for T

fn checked_from<T>(t: T) -> Option<Self>where Self: TryFrom<T>,

fn checked_into<T>(self) -> Option<T>where Self: TryInto<T>,

impl<T> Conv for T

fn conv<T>(self) -> Twhere Self: Into<T>,

impl<T> FmtForward for T

fn fmt_binary(self) -> FmtBinary<Self>where Self: Binary,

fn fmt_display(self) -> FmtDisplay<Self>where Self: Display,

fn fmt_lower_exp(self) -> FmtLowerExp<Self>where Self: LowerExp,

fn fmt_lower_hex(self) -> FmtLowerHex<Self>where Self: LowerHex,

fn fmt_octal(self) -> FmtOctal<Self>where Self: Octal,

fn fmt_pointer(self) -> FmtPointer<Self>where Self: Pointer,

fn fmt_upper_exp(self) -> FmtUpperExp<Self>where Self: UpperExp,

fn fmt_upper_hex(self) -> FmtUpperHex<Self>where Self: UpperHex,

fn fmt_list(self) -> FmtList<Self>where &'a Self: for<'a> IntoIterator,

impl<T> From<T> for T

fn from(t: T) -> T

Enum polkadot_node_subsystem::messages::NetworkBridgeTxMessage

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

impl<T> Any for T
where T: Any,

impl<T> AnySync for T
where T: Any + Send + Sync,

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

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

fn checked_from<T>(t: T) -> Option<Self>
where Self: TryFrom<T>,

fn checked_into<T>(self) -> Option<T>
where Self: TryInto<T>,

fn conv<T>(self) -> T
where Self: Into<T>,

fn fmt_binary(self) -> FmtBinary<Self>
where Self: Binary,

fn fmt_display(self) -> FmtDisplay<Self>
where Self: Display,

fn fmt_lower_exp(self) -> FmtLowerExp<Self>
where Self: LowerExp,

fn fmt_lower_hex(self) -> FmtLowerHex<Self>
where Self: LowerHex,

fn fmt_octal(self) -> FmtOctal<Self>
where Self: Octal,

fn fmt_pointer(self) -> FmtPointer<Self>
where Self: Pointer,

fn fmt_upper_exp(self) -> FmtUpperExp<Self>
where Self: UpperExp,

fn fmt_upper_hex(self) -> FmtUpperHex<Self>
where Self: UpperHex,

fn fmt_list(self) -> FmtList<Self>
where &'a Self: for<'a> IntoIterator,

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<Src, Dest> IntoTuple<Dest> for Src
where Dest: FromTuple<Src>,

impl<T, Outer> IsWrappedBy<Outer> for T
where Outer: AsRef<T> + AsMut<T> + From<T>, T: From<Outer>,

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

fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> R
where Self: Sized,

fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> R
where R: 'a,

fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> R
where R: 'a,

fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
where Self: Borrow<B>, B: 'a + ?Sized, R: 'a,

fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R, ) -> R
where Self: BorrowMut<B>, B: 'a + ?Sized, R: 'a,

fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
where Self: AsRef<U>, U: 'a + ?Sized, R: 'a,

fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
where Self: AsMut<U>, U: 'a + ?Sized, R: 'a,

fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
where Self: Deref<Target = T>, T: 'a + ?Sized, R: 'a,

fn pipe_deref_mut<'a, T, R>( &'a mut self, func: impl FnOnce(&'a mut T) -> R, ) -> R
where Self: DerefMut<Target = T> + Deref, T: 'a + ?Sized, R: 'a,

fn saturated_from<T>(t: T) -> Self
where Self: UniqueSaturatedFrom<T>,

fn saturated_into<T>(self) -> T
where Self: UniqueSaturatedInto<T>,

fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
where Self: Borrow<B>, B: ?Sized,

fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
where Self: BorrowMut<B>, B: ?Sized,

fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
where Self: AsRef<R>, R: ?Sized,

fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
where Self: AsMut<R>, R: ?Sized,

fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
where Self: Deref<Target = T>, T: ?Sized,

fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
where Self: DerefMut<Target = T> + Deref, T: ?Sized,

fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
where Self: Borrow<B>, B: ?Sized,

fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
where Self: BorrowMut<B>, B: ?Sized,

fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
where Self: AsRef<R>, R: ?Sized,

fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
where Self: AsMut<R>, R: ?Sized,

fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
where Self: Deref<Target = T>, T: ?Sized,

fn tap_deref_mut_dbg<T>(self, func: impl FnOnce(&mut T)) -> Self
where Self: DerefMut<Target = T> + Deref, T: ?Sized,

fn try_conv<T>(self) -> Result<T, Self::Error>
where Self: TryInto<T>,

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

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