Struct HoprNetworkBehavior

pub struct HoprNetworkBehavior {
    pub heartbeat: Behaviour<Ping, Pong>,
    pub ticket_aggregation: Behaviour<Vec<AcknowledgedTicket>, Result<Ticket, String>>,
    /* private fields */
}

Network Behavior definition for aggregated HOPR network functionality.

Individual network behaviors from the libp2p perspectives are aggregated under this type in order to create an aggregated network behavior capable of generating events for all component behaviors.

Fields

heartbeat: Behaviour<Ping, Pong>

ticket_aggregation: Behaviour<Vec<AcknowledgedTicket>, Result<Ticket, String>>

Implementations

impl HoprNetworkBehavior

pub fn new<T, U, V, W>( me: PeerId, network_events: T, onchain_events: U, heartbeat_requests: V, ticket_aggregation_processed_events: W, hb_timeout: Duration, ticket_aggregation_timeout: Duration, ) -> Self

where T: Stream<Item = NetworkTriggeredEvent> + Send + 'static, U: Stream<Item = PeerDiscovery> + Send + 'static, V: Stream<Item = (PeerId, PingQueryReplier)> + Send + 'static, W: Stream<Item = TicketAggregationProcessed<TicketAggregationResponseType, TicketAggregationRequestType>> + Send + 'static,

Trait Implementations

impl Debug for HoprNetworkBehavior

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

Formats the value using the given formatter.

impl NetworkBehaviour for HoprNetworkBehavior

where Behaviour: NetworkBehaviour, Behaviour: NetworkBehaviour, Behaviour: NetworkBehaviour, Behaviour<Ping, Pong>: NetworkBehaviour, Behaviour<Vec<AcknowledgedTicket>, Result<Ticket, String>>: NetworkBehaviour, Behaviour: NetworkBehaviour, HoprNetworkBehaviorEvent: From<<Behaviour as NetworkBehaviour>::ToSwarm> + From<<Behaviour as NetworkBehaviour>::ToSwarm> + From<<Behaviour as NetworkBehaviour>::ToSwarm> + From<<Behaviour<Ping, Pong> as NetworkBehaviour>::ToSwarm> + From<<Behaviour<Vec<AcknowledgedTicket>, Result<Ticket, String>> as NetworkBehaviour>::ToSwarm> + From<<Behaviour as NetworkBehaviour>::ToSwarm>,

type ConnectionHandler = ConnectionHandlerSelect<ConnectionHandlerSelect<ConnectionHandlerSelect<ConnectionHandlerSelect<ConnectionHandlerSelect<<Behaviour as NetworkBehaviour>::ConnectionHandler, <Behaviour as NetworkBehaviour>::ConnectionHandler>, <Behaviour as NetworkBehaviour>::ConnectionHandler>, <Behaviour<Codec<Ping, Pong>> as NetworkBehaviour>::ConnectionHandler>, <Behaviour<Codec<Vec<AcknowledgedTicket>, Result<Ticket, String>>> as NetworkBehaviour>::ConnectionHandler>, <Behaviour as NetworkBehaviour>::ConnectionHandler>

Handler for all the protocols the network behaviour supports.

type ToSwarm = HoprNetworkBehaviorEvent

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, port_use: PortUse, ) -> 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.