Struct Bitswap 

pub struct Bitswap {
    pub connected_peers: HashMap<PeerId, Ledger>,
    pub queued_blocks: UnboundedSender<(PeerId, Block)>,
    pub dont_have_tx: UnboundedSender<(PeerId, Cid)>,
    pub stats: HashMap<PeerId, Arc<Stats>>,
    /* private fields */
}

Network behaviour that handles sending and receiving IPFS blocks.

Fields

connected_peers: HashMap<PeerId, Ledger>

Ledger

queued_blocks: UnboundedSender<(PeerId, Block)>

Blocks queued to be sent

dont_have_tx: UnboundedSender<(PeerId, Cid)>

stats: HashMap<PeerId, Arc<Stats>>

Statistics related to peers.

Implementations

impl Bitswap

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

Return the wantlist of the local node

pub fn peer_wantlist(&self, peer: &PeerId) -> Option<Vec<(Cid, Priority)>>

Return the wantlist of a peer, if known

pub fn stats(&self) -> Stats

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

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

Connect to peer.

Called from Kademlia behaviour.

pub fn send_block(&mut self, peer_id: PeerId, block: Block)

Sends a block to the peer.

Called from a Strategy.

pub fn want_block(&mut self, cid: Cid, priority: Priority)

Queues the wanted block for all peers.

A user request

pub fn want_block_from_peers( &mut self, cid: Cid, priority: Priority, peers: &[PeerId], )

Queues the wanted block for specific peers.

A user request

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

Remove wanted blocks from ledger that we dont have

pub fn dont_have_for_peer(&mut self, peer_id: PeerId, cid: Cid)

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

Removes the block from our want list and updates all peers.

Can be either a user request or be called when the block was received.

Trait Implementations

impl Default for Bitswap

fn default() -> Self

Returns the “default value” for a type.

impl NetworkBehaviour for Bitswap

type ConnectionHandler = OneShotHandler<BitswapConfig, Message, MessageWrapper>

Handler for all the protocols the network behaviour supports.

type OutEvent = BitswapEvent

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

fn addresses_of_peer(&mut self, _peer_id: &PeerId) -> Vec<Multiaddr>

👎Deprecated: Use NetworkBehaviour::handle_pending_outbound_connection instead.

Addresses that this behaviour is aware of for this specific peer, and that may allow reaching the peer.

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

Informs the behaviour about an event from the Swarm.

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_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, source: PeerId, _connection: ConnectionId, message: MessageWrapper, )

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, ctx: &mut Context<'_>, _: &mut impl PollParameters, ) -> Poll<NetworkBehaviourAction<Self::OutEvent, Message>>

Polls for things that swarm should do.

fn new_handler(&mut self) -> Self::ConnectionHandler

👎Deprecated since 0.42.0: Use one or more of NetworkBehaviour::{handle_pending_inbound_connection,handle_established_inbound_connection,handle_pending_outbound_connection,handle_established_outbound_connection} instead.

Creates a new ConnectionHandler for a connection with a peer.

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_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.