Struct ForestBehaviour 

pub(super) struct ForestBehaviour {
    connection_limits: Behaviour,
    pub(super) blocked_peers: Behaviour<BlockedPeers>,
    pub(super) discovery: DiscoveryBehaviour,
    ping: Behaviour,
    gossipsub: Behaviour,
    pub(super) hello: HelloBehaviour,
    pub(super) chain_exchange: ChainExchangeBehaviour,
    pub(super) bitswap: BitswapBehaviour,
}

Libp2p behavior for the Forest node. This handles all sub protocols needed for a Filecoin node.

Fields

connection_limits: Behaviour

blocked_peers: Behaviour<BlockedPeers>

discovery: DiscoveryBehaviour

ping: Behaviour

gossipsub: Behaviour

hello: HelloBehaviour

chain_exchange: ChainExchangeBehaviour

bitswap: BitswapBehaviour

Implementations

impl ForestBehaviour

pub async fn new( local_key: &Keypair, config: &Libp2pConfig, network_name: &GenesisNetworkName, peer_manager: Arc<PeerManager>, ) -> Result<Self>

pub fn bootstrap(&mut self) -> Result<QueryId, String>

Bootstrap Kademlia network

pub fn publish( &mut self, topic: Topic, data: impl Into<Vec<u8>>, ) -> Result<MessageId, PublishError>

Publish data over the gossip network.

pub fn subscribe(&mut self, topic: &Topic) -> Result<bool, SubscriptionError>

Subscribe to a gossip topic.

pub fn peers(&self) -> &HashSet<PeerId>

Returns a set of peer ids

pub fn peer_addresses(&self) -> HashMap<PeerId, HashSet<Multiaddr>>

Returns a map of peer ids and their multi-addresses

pub fn peer_info(&self, peer_id: &PeerId) -> Option<&PeerInfo>

Trait Implementations

impl NetworkBehaviour for ForestBehaviour

where Behaviour: NetworkBehaviour, Behaviour<BlockedPeers>: NetworkBehaviour, DiscoveryBehaviour: NetworkBehaviour, Behaviour: NetworkBehaviour, Behaviour: NetworkBehaviour, HelloBehaviour: NetworkBehaviour, ChainExchangeBehaviour: NetworkBehaviour, BitswapBehaviour: NetworkBehaviour,

type ConnectionHandler = ConnectionHandlerSelect<ConnectionHandlerSelect<ConnectionHandlerSelect<ConnectionHandlerSelect<ConnectionHandlerSelect<ConnectionHandlerSelect<ConnectionHandlerSelect<<Behaviour as NetworkBehaviour>::ConnectionHandler, <Behaviour<BlockedPeers> as NetworkBehaviour>::ConnectionHandler>, <DiscoveryBehaviour as NetworkBehaviour>::ConnectionHandler>, <Behaviour as NetworkBehaviour>::ConnectionHandler>, <Behaviour as NetworkBehaviour>::ConnectionHandler>, <HelloBehaviour as NetworkBehaviour>::ConnectionHandler>, <ChainExchangeBehaviour as NetworkBehaviour>::ConnectionHandler>, <BitswapBehaviour as NetworkBehaviour>::ConnectionHandler>

Handler for all the protocols the network behaviour supports.

type ToSwarm = ForestBehaviourEvent

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.