Struct ExternalEventHandler 

pub struct ExternalEventHandler {
    request_response_sender: Sender<Bytes>,
    dropped_messages: Arc<dyn Counter>,
}

The external event handler

Fields

request_response_sender: Sender<Bytes>

The sender to the request-response protocol

dropped_messages: Arc<dyn Counter>

Counts inbound request-response messages dropped because the channel was full

Implementations

impl ExternalEventHandler

pub async fn new<P>( tasks: &mut TaskList, request_response_sender: Sender<Bytes>, outbound_message_receiver: Receiver<OutboundMessage>, consensus_handle: Arc<ConsensusHandle<SeqTypes, Arc<P>>>, public_key: PubKey, dropped_messages: Arc<dyn Counter>, ) -> Result<Self>

where P: SequencerPersistence,

pub async fn handle_event(&self, external_message_bytes: &[u8]) -> Result<()>

Handles an event

Errors

If the message type is unknown or if there is an error serializing or deserializing the message

async fn outbound_message_loop<P>( receiver: Receiver<OutboundMessage>, consensus_handle: Arc<ConsensusHandle<SeqTypes, Arc<P>>>, public_key: PubKey, )

where P: SequencerPersistence,

The main loop for sending outbound messages.

async fn send_via_coordinator( client_api: &ClientApi<SeqTypes>, message: OutboundMessage, public_key: PubKey, )

Send an outbound message through the coordinator’s network.

The coordinator’s network sends external payloads over the wire verbatim, so they must be self-framing: wrap the payload in the versioned Message envelope, which the receiving side’s fallback decoder recognizes and unwraps.

Trait Implementations

impl Clone for ExternalEventHandler

fn clone(&self) -> ExternalEventHandler

Returns a duplicate of the value.

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

Performs copy-assignment from source.