Struct libp2p_tcp::TcpConfig
source · pub struct TcpConfig { /* private fields */ }
Expand description
Represents the configuration for a TCP/IP transport capability for libp2p.
The TCP sockets created by libp2p will need to be progressed by running the futures and streams obtained by libp2p through the tokio reactor.
Implementations
sourceimpl TcpConfig
impl TcpConfig
sourcepub fn recv_buffer_size(self, value: usize) -> Self
pub fn recv_buffer_size(self, value: usize) -> Self
Sets the size of the recv buffer size to set for opened sockets.
sourcepub fn send_buffer_size(self, value: usize) -> Self
pub fn send_buffer_size(self, value: usize) -> Self
Sets the size of the send buffer size to set for opened sockets.
Trait Implementations
sourceimpl Transport for TcpConfig
impl Transport for TcpConfig
type Output = TcpTransStream
type Output = TcpTransStream
The raw connection to a peer.
type Listener = TcpListenStream
type Listener = TcpListenStream
The listener produces incoming connections. Read more
type ListenerUpgrade = FutureResult<<TcpConfig as Transport>::Output, Error>
type ListenerUpgrade = FutureResult<<TcpConfig as Transport>::Output, Error>
After a connection has been received, we may need to do some asynchronous pre-processing
on it (e.g. an intermediary protocol negotiation). While this pre-processing takes place,
we want to be able to continue polling on the listener. Read more
type Dial = TcpDialFut
type Dial = TcpDialFut
A future which indicates that we are currently dialing to a peer.
sourcefn listen_on(
self,
addr: Multiaddr
) -> Result<(Self::Listener, Multiaddr), TransportError<Self::Error>>
fn listen_on(
self,
addr: Multiaddr
) -> Result<(Self::Listener, Multiaddr), TransportError<Self::Error>>
Listen on the given multiaddr. Returns a stream of incoming connections, plus a modified
version of the
Multiaddr
. This new Multiaddr
is the one that that should be advertised
to other nodes, instead of the one passed as parameter. Read moresourcefn dial(self, addr: Multiaddr) -> Result<Self::Dial, TransportError<Self::Error>>
fn dial(self, addr: Multiaddr) -> Result<Self::Dial, TransportError<Self::Error>>
Dial the given multi-addr. Read more
sourcefn nat_traversal(
&self,
server: &Multiaddr,
observed: &Multiaddr
) -> Option<Multiaddr>
fn nat_traversal(
&self,
server: &Multiaddr,
observed: &Multiaddr
) -> Option<Multiaddr>
Takes a multiaddress we’re listening on (
server
), and tries to convert it to an
externally-visible multiaddress. In order to do so, we pass an observed
address which
a remote node observes for one of our dialers. Read moresourcefn map<F, O>(self, map: F) -> Map<Self, F>where
Self: Sized,
F: FnOnce(Self::Output, ConnectedPoint) -> O + Clone,
fn map<F, O>(self, map: F) -> Map<Self, F>where
Self: Sized,
F: FnOnce(Self::Output, ConnectedPoint) -> O + Clone,
Applies a function on the output of the
Transport
.sourcefn map_err<F, TNewErr>(self, map_err: F) -> MapErr<Self, F>where
Self: Sized,
F: FnOnce(Self::Error) -> TNewErr + Clone,
fn map_err<F, TNewErr>(self, map_err: F) -> MapErr<Self, F>where
Self: Sized,
F: FnOnce(Self::Error) -> TNewErr + Clone,
Applies a function on the errors generated by the futures of the
Transport
.sourcefn or_transport<T>(self, other: T) -> OrTransport<Self, T>where
Self: Sized,
fn or_transport<T>(self, other: T) -> OrTransport<Self, T>where
Self: Sized,
sourcefn and_then<C, F, O>(self, upgrade: C) -> AndThen<Self, C>where
Self: Sized,
C: FnOnce(Self::Output, ConnectedPoint) -> F + Clone,
F: IntoFuture<Item = O>,
fn and_then<C, F, O>(self, upgrade: C) -> AndThen<Self, C>where
Self: Sized,
C: FnOnce(Self::Output, ConnectedPoint) -> F + Clone,
F: IntoFuture<Item = O>,
Wraps this transport inside an upgrade. Whenever a connection that uses this transport
is established, it is wrapped inside the upgrade. Read more
sourcefn with_timeout(self, timeout: Duration) -> TransportTimeout<Self>where
Self: Sized,
fn with_timeout(self, timeout: Duration) -> TransportTimeout<Self>where
Self: Sized,
Adds a timeout to the connection and upgrade steps for all the sockets created by
the transport. Read more
sourcefn with_outbound_timeout(self, timeout: Duration) -> TransportTimeout<Self>where
Self: Sized,
fn with_outbound_timeout(self, timeout: Duration) -> TransportTimeout<Self>where
Self: Sized,
Adds a timeout to the connection and upgrade steps for all the outgoing sockets created
by the transport. Read more
sourcefn with_inbound_timeout(self, timeout: Duration) -> TransportTimeout<Self>where
Self: Sized,
fn with_inbound_timeout(self, timeout: Duration) -> TransportTimeout<Self>where
Self: Sized,
Adds a timeout to the connection and upgrade steps for all the incoming sockets created
by the transport. Read more
Auto Trait Implementations
impl RefUnwindSafe for TcpConfig
impl Send for TcpConfig
impl Sync for TcpConfig
impl Unpin for TcpConfig
impl UnwindSafe for TcpConfig
Blanket Implementations
sourceimpl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more