Enum polkadot_node_subsystem::messages::NetworkBridgeTxMessage

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

Messages received from other subsystems by the network bridge subsystem.

Variants

ReportPeer(PeerId, UnifiedReputationChange)

Report a peer for their actions.

DisconnectPeer(PeerId, PeerSet)

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

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

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

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

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

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

Send a batch of validation messages.

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

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

Send a batch of collation messages.

NOTE: Messages will be processed in order.

SendRequests(Vec<Requests, Global>, IfDisconnected)

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

ConnectToValidators

Fields

validator_ids: Vec<Public, Global>

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.

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.

ConnectToResolvedValidators

Fields

validator_addrs: Vec<HashSet<Multiaddr, RandomState>, Global>

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

peer_set: PeerSet

The peer set we want the connection on.

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

Trait Implementations

impl AssociateOutgoing for NetworkBridgeTxMessage

type OutgoingMessages = NetworkBridgeTxOutgoingMessages

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

impl Debug for NetworkBridgeTxMessage

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

Formats the value using the given formatter.

impl From<NetworkBridgeTxMessage> for AllMessages

fn from(message: NetworkBridgeTxMessage) -> AllMessages

Converts to this type from the input type.

impl From<NetworkBridgeTxMessage> for ApprovalDistributionOutgoingMessages

fn from(message: NetworkBridgeTxMessage) -> ApprovalDistributionOutgoingMessages

Converts to this type from the input type.

impl From<NetworkBridgeTxMessage> for AvailabilityDistributionOutgoingMessages

fn from( message: NetworkBridgeTxMessage ) -> AvailabilityDistributionOutgoingMessages

Converts to this type from the input type.

impl From<NetworkBridgeTxMessage> for AvailabilityRecoveryOutgoingMessages

fn from(message: NetworkBridgeTxMessage) -> AvailabilityRecoveryOutgoingMessages

Converts to this type from the input type.

impl From<NetworkBridgeTxMessage> for BitfieldDistributionOutgoingMessages

fn from(message: NetworkBridgeTxMessage) -> BitfieldDistributionOutgoingMessages

Converts to this type from the input type.

impl From<NetworkBridgeTxMessage> for CollatorProtocolOutgoingMessages

fn from(message: NetworkBridgeTxMessage) -> CollatorProtocolOutgoingMessages

Converts to this type from the input type.

impl From<NetworkBridgeTxMessage> for DisputeDistributionOutgoingMessages

fn from(message: NetworkBridgeTxMessage) -> DisputeDistributionOutgoingMessages

Converts to this type from the input type.

impl From<NetworkBridgeTxMessage> for GossipSupportOutgoingMessages

fn from(message: NetworkBridgeTxMessage) -> GossipSupportOutgoingMessages

Converts to this type from the input type.

impl From<NetworkBridgeTxMessage> for StatementDistributionOutgoingMessages

fn from( message: NetworkBridgeTxMessage ) -> StatementDistributionOutgoingMessages

Converts to this type from the input type.