Struct BillPouchBehaviour 

pub struct BillPouchBehaviour {
    pub gossipsub: Behaviour,
    pub kad: Behaviour<MemoryStore>,
    pub identify: Behaviour,
    pub mdns: Behaviour,
    pub fragment_exchange: Behaviour<FragmentRequest, FragmentResponse>,
    pub autonat: Behaviour,
    pub relay: Behaviour,
}

Single combined behaviour injected into the libp2p Swarm.

All seven sub-behaviours are polled by the swarm in a single select!-style event loop inside run_network_loop.

Fields

gossipsub: Behaviour

Flooding pub/sub: used to broadcast NodeInfo announcements.

kad: Behaviour<MemoryStore>

Kademlia DHT: distributed peer discovery and content addressing.

identify: Behaviour

Identify: exchange protocol version string and listen addresses with peers.

mdns: Behaviour

mDNS: zero-configuration local-network peer discovery via multicast DNS.

fragment_exchange: Behaviour<FragmentRequest, FragmentResponse>

Direct fragment fetch/push between Pouch nodes.

autonat: Behaviour

AutoNAT: probes remote peers to detect whether this node is publicly reachable.

Reports [autonat::NatStatus] changes so the daemon can decide whether to activate relay-assisted connectivity.

relay: Behaviour

Relay client: allows this node to route connections through a relay peer when a direct connection is not possible (e.g. behind symmetric NAT).

Implementations

impl BillPouchBehaviour

pub fn new(keypair: &Keypair, relay_client: Behaviour) -> Result<Self>

Build the combined behaviour from a keypair and a relay client handle.

The relay_client is obtained from the SwarmBuilder::with_relay_client() step and must be passed in rather than constructed here.

Configures:

• Gossipsub with strict message signing and a 10-second heartbeat.
• Kademlia with an in-memory record store.
• Identify with the /billpouch/id/1.0.0 protocol string.
• mDNS with default settings.
• RequestResponse with the /billpouch/fragment/1.1.0 protocol.
• AutoNAT with default probe config.
• Relay client (handle passed by the SwarmBuilder).

Errors

Returns an error if gossipsub config validation fails or mDNS cannot bind its multicast socket.

Trait Implementations

impl NetworkBehaviour for BillPouchBehaviour

where Behaviour: NetworkBehaviour, Behaviour<MemoryStore>: NetworkBehaviour, Behaviour: NetworkBehaviour, Behaviour: NetworkBehaviour, Behaviour<FragmentRequest, FragmentResponse>: NetworkBehaviour, Behaviour: NetworkBehaviour, Behaviour: NetworkBehaviour,

type ConnectionHandler = ConnectionHandlerSelect<ConnectionHandlerSelect<ConnectionHandlerSelect<ConnectionHandlerSelect<ConnectionHandlerSelect<ConnectionHandlerSelect<<Behaviour as NetworkBehaviour>::ConnectionHandler, <Behaviour<MemoryStore> as NetworkBehaviour>::ConnectionHandler>, <Behaviour as NetworkBehaviour>::ConnectionHandler>, <Behaviour<Tokio> as NetworkBehaviour>::ConnectionHandler>, <Behaviour<Codec<FragmentRequest, FragmentResponse>> as NetworkBehaviour>::ConnectionHandler>, <Behaviour as NetworkBehaviour>::ConnectionHandler>, <Behaviour as NetworkBehaviour>::ConnectionHandler>

Handler for all the protocols the network behaviour supports.

type ToSwarm = BillPouchBehaviourEvent

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.