Struct rust_ipfs::p2p::bitswap::Behaviour

pub struct Behaviour { /* private fields */ }

Implementations

impl Behaviour

pub fn new(store: &Repo) -> Self

pub fn get(&mut self, cid: &Cid, providers: &[PeerId])

pub fn gets(&mut self, cid: Vec<Cid>, providers: &[PeerId])

pub fn local_wantlist(&self) -> Vec<Cid>

pub fn peer_wantlist(&self, peer_id: PeerId) -> Vec<Cid>

pub fn cancel(&mut self, cid: Cid)

pub fn notify_new_blocks(&mut self, cid: impl IntoIterator<Item = Cid>)

Trait Implementations

impl NetworkBehaviour for Behaviour

type ConnectionHandler = OneShotHandler<BitswapProtocol, BitswapMessage, Message>

Handler for all the protocols the network behaviour supports.

type ToSwarm = Event

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

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

Callback that is invoked for every new inbound connection.

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

Callback that is invoked for every outbound connection attempt.

fn handle_established_inbound_connection( &mut self, _: ConnectionId, _: PeerId, _: &Multiaddr, _: &Multiaddr ) -> Result<THandler<Self>, ConnectionDenied>

Callback that is invoked for every established inbound connection.

fn handle_established_outbound_connection( &mut self, _: ConnectionId, _: PeerId, _: &Multiaddr, _: 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 on_swarm_event(&mut self, event: FromSwarm<'_>)

Informs the behaviour about an event from the Swarm.

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

Polls for things that swarm should do.