Struct swarm_nl::core::DefaultHandler

pub struct DefaultHandler;

Default network event handler.

Trait Implementations

impl Clone for DefaultHandler

fn clone(&self) -> DefaultHandler

Returns a copy of the value.

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

Performs copy-assignment from source.

impl EventHandler for DefaultHandler

Implement EventHandler for DefaultHandler

fn rpc_incoming_message_handled(&mut self, data: Vec<Vec<u8>>) -> Vec<Vec<u8>>

Echo the message back to the sender.

fn gossipsub_incoming_message_handled( &mut self, _source: PeerId, _data: Vec<String> )

Echo the incoming gossip message to the console.

fn new_listen_addr( &mut self, _local_peer_id: PeerId, _listener_id: ListenerId, _addr: Multiaddr )

Event that informs the application that we have started listening on a new multiaddr.

fn routing_table_updated(&mut self, _peer_id: PeerId)

Event that informs the application that a new peer (with its location details) has just been added to the routing table.

fn connection_established( &mut self, _peer_id: PeerId, _connection_id: ConnectionId, _endpoint: &ConnectedPoint, _num_established: NonZeroU32, _established_in: Duration )

Event that informs the application about a newly established connection to a peer.

fn connection_closed( &mut self, _peer_id: PeerId, _connection_id: ConnectionId, _endpoint: &ConnectedPoint, _num_established: u32, _cause: Option<ConnectionError> )

Event that informs the application about a closed connection to a peer.

fn expired_listen_addr(&mut self, _listener_id: ListenerId, _address: Multiaddr)

Event that announces expired listen address.

fn listener_closed( &mut self, _listener_id: ListenerId, _addresses: Vec<Multiaddr> )

Event that announces a closed listener.

fn listener_error(&mut self, _listener_id: ListenerId)

Event that announces a listener error.

fn dialing(&mut self, _peer_id: Option<PeerId>, _connection_id: ConnectionId)

Event that announces a dialing attempt.

fn new_external_addr_candidate(&mut self, _address: Multiaddr)

Event that announces a new external address candidate.

fn external_addr_confirmed(&mut self, _address: Multiaddr)

Event that announces a confirmed external address.

fn external_addr_expired(&mut self, _address: Multiaddr)

Event that announces an expired external address.

fn incoming_connection( &mut self, _connection_id: ConnectionId, _local_addr: Multiaddr, _send_back_addr: Multiaddr )

Event that announces new connection arriving on a listener and in the process of protocol negotiation.

fn incoming_connection_error( &mut self, _connection_id: ConnectionId, _local_addr: Multiaddr, _send_back_addr: Multiaddr )

Event that announces an error happening on an inbound connection during its initial handshake.

fn outgoing_connection_error( &mut self, _connection_id: ConnectionId, _peer_id: Option<PeerId> )

Event that announces an error happening on an outbound connection during its initial handshake.

fn outbound_ping_success(&mut self, _peer_id: PeerId, _duration: Duration)

Event that announces the arrival of a pong message from a peer. The duration it took for a round trip is also returned.

fn outbound_ping_error(&mut self, _peer_id: PeerId, _err_type: Failure)

Event that announces a Ping error.

fn identify_info_recieved(&mut self, _peer_id: PeerId, _info: Info)

Event that announces the arrival of a PeerInfo via the Identify protocol.

fn kademlia_put_record_success(&mut self, _key: Vec<u8>)

Event that announces the successful write of a record to the DHT.

fn kademlia_put_record_error(&mut self)

Event that announces the failure of a node to save a record.

fn kademlia_start_providing_success(&mut self, _key: Vec<u8>)

Event that announces a node as a provider of a record in the DHT.

fn kademlia_start_providing_error(&mut self)

Event that announces the failure of a node to become a provider of a record in the DHT.

fn gossipsub_unsubscribe_message_recieved( &mut self, _peer_id: PeerId, _topic: String )

Event that announces that a peer has just left a network.

fn gossipsub_subscribe_message_recieved( &mut self, _peer_id: PeerId, _topic: String )

Event that announces that a peer has just joined a network.

fn gossipsub_incoming_message_filtered( &mut self, _propagation_source: PeerId, _message_id: MessageId, _source: Option<PeerId>, _topic: String, _data: Vec<String> ) -> bool

Event that announces the beginning of the filtering and authentication of the incoming gossip message. It returns a boolean to specify whether the massage should be dropped or should reach the application. All incoming messages are allowed in by default.