Struct libp2p_bitswap::Bitswap [−][src]
pub struct Bitswap<P: StoreParams> { /* fields omitted */ }
Expand description
Network behaviour that handles sending and receiving blocks.
Implementations
impl<P: StoreParams> Bitswap<P>
[src]
impl<P: StoreParams> Bitswap<P>
[src]pub fn new<S: BitswapStore<Params = P>>(config: BitswapConfig, store: S) -> Self
[src]
pub fn new<S: BitswapStore<Params = P>>(config: BitswapConfig, store: S) -> Self
[src]Creates a new Bitswap
behaviour.
pub fn add_address(&mut self, peer_id: &PeerId, addr: Multiaddr)
[src]
pub fn add_address(&mut self, peer_id: &PeerId, addr: Multiaddr)
[src]Adds an address for a peer.
pub fn remove_address(&mut self, peer_id: &PeerId, addr: &Multiaddr)
[src]
pub fn remove_address(&mut self, peer_id: &PeerId, addr: &Multiaddr)
[src]Removes an address for a peer.
pub fn get(&mut self, cid: Cid, peers: impl Iterator<Item = PeerId>) -> QueryId
[src]
pub fn get(&mut self, cid: Cid, peers: impl Iterator<Item = PeerId>) -> QueryId
[src]Starts a get query with an initial guess of providers.
pub fn sync(
&mut self,
cid: Cid,
peers: Vec<PeerId>,
missing: impl Iterator<Item = Cid>
) -> QueryId
[src]
pub fn sync(
&mut self,
cid: Cid,
peers: Vec<PeerId>,
missing: impl Iterator<Item = Cid>
) -> QueryId
[src]Starts a sync query with an the initial set of missing blocks.
pub fn cancel(&mut self, id: QueryId) -> bool
[src]
pub fn cancel(&mut self, id: QueryId) -> bool
[src]Cancels an in progress query. Returns true if a query was cancelled.
pub fn register_metrics(&self, registry: &Registry) -> Result<()>
[src]
pub fn register_metrics(&self, registry: &Registry) -> Result<()>
[src]Registers prometheus metrics.
Trait Implementations
impl<P: StoreParams> NetworkBehaviour for Bitswap<P>
[src]
impl<P: StoreParams> NetworkBehaviour for Bitswap<P>
[src]type ProtocolsHandler = <RequestResponse<BitswapCodec<P>> as NetworkBehaviour>::ProtocolsHandler
type ProtocolsHandler = <RequestResponse<BitswapCodec<P>> as NetworkBehaviour>::ProtocolsHandler
Handler for all the protocols the network behaviour supports.
type OutEvent = BitswapEvent
type OutEvent = BitswapEvent
Event generated by the NetworkBehaviour
and that the swarm will report back.
fn new_handler(&mut self) -> Self::ProtocolsHandler
[src]
fn new_handler(&mut self) -> Self::ProtocolsHandler
[src]Creates a new ProtocolsHandler
for a connection with a peer. Read more
fn addresses_of_peer(&mut self, peer_id: &PeerId) -> Vec<Multiaddr>
[src]
fn addresses_of_peer(&mut self, peer_id: &PeerId) -> Vec<Multiaddr>
[src]Addresses that this behaviour is aware of for this specific peer, and that may allow reaching the peer. Read more
fn inject_connected(&mut self, peer_id: &PeerId)
[src]
fn inject_connected(&mut self, peer_id: &PeerId)
[src]Indicate to the behaviour that we connected to the node with the given peer id. Read more
fn inject_disconnected(&mut self, peer_id: &PeerId)
[src]
fn inject_disconnected(&mut self, peer_id: &PeerId)
[src]Indicates to the behaviour that we disconnected from the node with the given peer id. Read more
fn inject_connection_established(
&mut self,
peer_id: &PeerId,
conn: &ConnectionId,
endpoint: &ConnectedPoint
)
[src]
fn inject_connection_established(
&mut self,
peer_id: &PeerId,
conn: &ConnectionId,
endpoint: &ConnectedPoint
)
[src]Informs the behaviour about a newly established connection to a peer.
fn inject_connection_closed(
&mut self,
peer_id: &PeerId,
conn: &ConnectionId,
endpoint: &ConnectedPoint
)
[src]
fn inject_connection_closed(
&mut self,
peer_id: &PeerId,
conn: &ConnectionId,
endpoint: &ConnectedPoint
)
[src]Informs the behaviour about a closed connection to a peer. Read more
fn inject_addr_reach_failure(
&mut self,
peer_id: Option<&PeerId>,
addr: &Multiaddr,
error: &dyn Error
)
[src]
fn inject_addr_reach_failure(
&mut self,
peer_id: Option<&PeerId>,
addr: &Multiaddr,
error: &dyn Error
)
[src]Indicates to the behaviour that we tried to reach an address, but failed. Read more
fn inject_dial_failure(&mut self, peer_id: &PeerId)
[src]
fn inject_dial_failure(&mut self, peer_id: &PeerId)
[src]Indicates to the behaviour that we tried to dial all the addresses known for a node, but failed. Read more
fn inject_new_listen_addr(&mut self, id: ListenerId, addr: &Multiaddr)
[src]
fn inject_new_listen_addr(&mut self, id: ListenerId, addr: &Multiaddr)
[src]Indicates to the behaviour that we have started listening on a new multiaddr.
fn inject_expired_listen_addr(&mut self, id: ListenerId, addr: &Multiaddr)
[src]
fn inject_expired_listen_addr(&mut self, id: ListenerId, addr: &Multiaddr)
[src]Indicates to the behaviour that a multiaddr we were listening on has expired, which means that we are no longer listening in it. Read more
fn inject_new_external_addr(&mut self, addr: &Multiaddr)
[src]
fn inject_new_external_addr(&mut self, addr: &Multiaddr)
[src]Indicates to the behaviour that we have discovered a new external address for us.
fn inject_expired_external_addr(&mut self, addr: &Multiaddr)
[src]
fn inject_expired_external_addr(&mut self, addr: &Multiaddr)
[src]Indicates to the behaviour that an external address was removed.
fn inject_listener_error(&mut self, id: ListenerId, err: &(dyn Error + 'static))
[src]
fn inject_listener_error(&mut self, id: ListenerId, err: &(dyn Error + 'static))
[src]A listener experienced an error.
fn inject_listener_closed(&mut self, id: ListenerId, reason: Result<(), &Error>)
[src]
fn inject_listener_closed(&mut self, id: ListenerId, reason: Result<(), &Error>)
[src]A listener closed.
fn inject_event(
&mut self,
peer_id: PeerId,
conn: ConnectionId,
event: <Self::ProtocolsHandler as ProtocolsHandler>::OutEvent
)
[src]
fn inject_event(
&mut self,
peer_id: PeerId,
conn: ConnectionId,
event: <Self::ProtocolsHandler as ProtocolsHandler>::OutEvent
)
[src]Informs the behaviour about an event generated by the handler dedicated to the peer identified by peer_id
.
for the behaviour. Read more
fn poll(
&mut self,
cx: &mut Context<'_>,
pp: &mut impl PollParameters
) -> Poll<NetworkBehaviourAction<<Self::ProtocolsHandler as ProtocolsHandler>::InEvent, Self::OutEvent>>
[src]
fn poll(
&mut self,
cx: &mut Context<'_>,
pp: &mut impl PollParameters
) -> Poll<NetworkBehaviourAction<<Self::ProtocolsHandler as ProtocolsHandler>::InEvent, Self::OutEvent>>
[src]Polls for things that swarm should do. Read more
fn inject_address_change(
&mut self,
&PeerId,
&ConnectionId,
_old: &ConnectedPoint,
_new: &ConnectedPoint
)
fn inject_address_change(
&mut self,
&PeerId,
&ConnectionId,
_old: &ConnectedPoint,
_new: &ConnectedPoint
)
Informs the behaviour that the [ConnectedPoint
] of an existing connection has changed.
fn inject_new_listener(&mut self, _id: ListenerId)
fn inject_new_listener(&mut self, _id: ListenerId)
Indicates to the behaviour that a new listener was created.
Auto Trait Implementations
impl<P> !RefUnwindSafe for Bitswap<P>
impl<P> Send for Bitswap<P>
impl<P> Sync for Bitswap<P>
impl<P> Unpin for Bitswap<P>
impl<P> !UnwindSafe for Bitswap<P>
Blanket Implementations
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]pub fn borrow_mut(&mut self) -> &mut T
[src]
pub fn borrow_mut(&mut self) -> &mut T
[src]Mutably borrows from an owned value. Read more
impl<T> Instrument for T
[src]
impl<T> Instrument for T
[src]fn instrument(self, span: Span) -> Instrumented<Self>
[src]
fn instrument(self, span: Span) -> Instrumented<Self>
[src]Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
fn in_current_span(self) -> Instrumented<Self>
[src]
fn in_current_span(self) -> Instrumented<Self>
[src]impl<T> Same<T> for T
impl<T> Same<T> for T
type Output = T
type Output = T
Should always be Self
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,