Struct fuel_core_p2p::behavior::FuelBehaviour

pub struct FuelBehaviour { /* private fields */ }

Handles all p2p protocols needed for Fuel.

Implementations

impl FuelBehaviour

pub fn add_addresses_to_discovery( &mut self, peer_id: &PeerId, addresses: Vec<Multiaddr>, )

pub fn publish_message( &mut self, topic: GossipTopic, encoded_data: Vec<u8>, ) -> Result<MessageId, PublishError>

pub fn send_request_msg( &mut self, message_request: RequestMessage, peer_id: &PeerId, ) -> OutboundRequestId

pub fn send_response_msg( &mut self, channel: ResponseChannel<ResponseMessage>, message: ResponseMessage, ) -> Result<(), ResponseMessage>

pub fn report_message_validation_result( &mut self, msg_id: &MessageId, propagation_source: &PeerId, acceptance: MessageAcceptance, ) -> Option<f64>

pub fn update_block_height(&mut self, block_height: BlockHeight)

pub fn block_peer(&mut self, peer_id: PeerId)

Trait Implementations

impl NetworkBehaviour for FuelBehaviour

where Behaviour<BlockedPeers>: NetworkBehaviour, Behaviour: NetworkBehaviour, Behaviour: NetworkBehaviour, Behaviour: NetworkBehaviour, Behaviour: NetworkBehaviour, Behaviour: NetworkBehaviour, Behaviour<PostcardCodec>: NetworkBehaviour,

type ConnectionHandler = ConnectionHandlerSelect<ConnectionHandlerSelect<ConnectionHandlerSelect<ConnectionHandlerSelect<ConnectionHandlerSelect<ConnectionHandlerSelect<<Behaviour<BlockedPeers> as NetworkBehaviour>::ConnectionHandler, <Behaviour as NetworkBehaviour>::ConnectionHandler>, <Behaviour as NetworkBehaviour>::ConnectionHandler>, <Behaviour as NetworkBehaviour>::ConnectionHandler>, <Behaviour as NetworkBehaviour>::ConnectionHandler>, <Behaviour as NetworkBehaviour>::ConnectionHandler>, <Behaviour<PostcardCodec> as NetworkBehaviour>::ConnectionHandler>

Handler for all the protocols the network behaviour supports.

type ToSwarm = FuelBehaviourEvent

Event generated by the NetworkBehaviour and that the swarm will report back.

fn handle_pending_inbound_connection( &mut self, connection_id: ConnectionId, local_addr: &Multiaddr, remote_addr: &Multiaddr, ) -> Result<(), ConnectionDenied>

Callback that is invoked for every new inbound connection.

fn handle_established_inbound_connection( &mut self, connection_id: ConnectionId, peer: PeerId, local_addr: &Multiaddr, remote_addr: &Multiaddr, ) -> Result<THandler<Self>, ConnectionDenied>

Callback that is invoked for every established inbound connection.

fn handle_pending_outbound_connection( &mut self, connection_id: ConnectionId, maybe_peer: Option<PeerId>, addresses: &[Multiaddr], effective_role: Endpoint, ) -> Result<Vec<Multiaddr>, ConnectionDenied>

Callback that is invoked for every outbound connection attempt.

fn handle_established_outbound_connection( &mut self, connection_id: ConnectionId, peer: PeerId, addr: &Multiaddr, role_override: Endpoint, ) -> Result<THandler<Self>, ConnectionDenied>

Callback that is invoked for every established outbound connection.

fn on_connection_handler_event( &mut self, peer_id: PeerId, connection_id: ConnectionId, event: THandlerOutEvent<Self>, )

Informs the behaviour about an event generated by the ConnectionHandler dedicated to the peer identified by peer_id. for the behaviour.

fn poll( &mut self, cx: &mut Context<'_>, ) -> Poll<ToSwarm<Self::ToSwarm, THandlerInEvent<Self>>>

Polls for things that swarm should do.

fn on_swarm_event(&mut self, event: FromSwarm<'_>)

Informs the behaviour about an event from the Swarm.