Struct libp2p_relay::RelayTransport [−][src]
A Transport
wrapping another Transport
enabling relay capabilities.
Allows the local node to:
-
Use inner wrapped transport as before.
relay_transport.dial(Multiaddr::empty().with(Protocol::Memory(42)));
-
Establish relayed connections by dialing
/p2p-circuit
addresses.let dst_addr_via_relay = Multiaddr::empty() .with(Protocol::Memory(40)) // Relay address. .with(Protocol::P2p(PeerId::random().into())) // Relay peer id. .with(Protocol::P2pCircuit) // Signal to connect via relay and not directly. .with(Protocol::Memory(42)) // Destination address. .with(Protocol::P2p(PeerId::random().into())); // Destination peer id. relay_transport.dial(dst_addr_via_relay).unwrap();
-
Listen for incoming relayed connections via specific relay.
let relay_addr = Multiaddr::empty() .with(Protocol::Memory(40)) // Relay address. .with(Protocol::P2p(PeerId::random().into())) // Relay peer id. .with(Protocol::P2pCircuit); // Signal to listen via remote relay node. relay_transport.listen_on(relay_addr).unwrap();
-
Listen for incoming relayed connections via any relay.
Note: Without this listener, incoming relayed connections from relays, that the local node is not explicitly listening via, are dropped.
let addr = Multiaddr::empty() .with(Protocol::P2pCircuit); // Signal to listen via any relay. relay_transport.listen_on(addr).unwrap();
Trait Implementations
impl<T: Clone> Clone for RelayTransport<T>
[src]
fn clone(&self) -> RelayTransport<T>
[src]
pub fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl<T: Transport + Clone> Transport for RelayTransport<T>
[src]
type Output = EitherOutput<<T as Transport>::Output, Connection>
The result of a connection setup process, including protocol upgrades. Read more
type Error = EitherError<<T as Transport>::Error, RelayError>
An error that occurred during connection setup.
type Listener = RelayListener<T>
type ListenerUpgrade = RelayedListenerUpgrade<T>
type Dial = EitherFuture<<T as Transport>::Dial, BoxFuture<'static, Result<Connection, RelayError>>>
fn listen_on(
self,
addr: Multiaddr
) -> Result<Self::Listener, TransportError<Self::Error>>
[src]
self,
addr: Multiaddr
) -> Result<Self::Listener, TransportError<Self::Error>>
fn dial(
self,
addr: Multiaddr
) -> Result<Self::Dial, TransportError<Self::Error>>
[src]
self,
addr: Multiaddr
) -> Result<Self::Dial, TransportError<Self::Error>>
fn address_translation(
&self,
server: &Multiaddr,
observed: &Multiaddr
) -> Option<Multiaddr>
[src]
&self,
server: &Multiaddr,
observed: &Multiaddr
) -> Option<Multiaddr>
pub fn boxed(self) -> Boxed<Self::Output> where
Self: Transport + Clone + Send + Sync + 'static,
Self::Dial: Send,
Self::Dial: 'static,
Self::Listener: Send,
Self::Listener: 'static,
Self::ListenerUpgrade: Send,
Self::ListenerUpgrade: 'static,
Self::Error: Send,
Self::Error: Sync,
[src]
Self: Transport + Clone + Send + Sync + 'static,
Self::Dial: Send,
Self::Dial: 'static,
Self::Listener: Send,
Self::Listener: 'static,
Self::ListenerUpgrade: Send,
Self::ListenerUpgrade: 'static,
Self::Error: Send,
Self::Error: Sync,
pub fn map<F, O>(self, f: F) -> Map<Self, F> where
F: FnOnce(Self::Output, ConnectedPoint) -> O + Clone,
[src]
F: FnOnce(Self::Output, ConnectedPoint) -> O + Clone,
pub fn map_err<F, E>(self, f: F) -> MapErr<Self, F> where
F: FnOnce(Self::Error) -> E + Clone,
[src]
F: FnOnce(Self::Error) -> E + Clone,
pub fn or_transport<U>(self, other: U) -> OrTransport<Self, U> where
U: Transport,
<U as Transport>::Error: 'static,
[src]
U: Transport,
<U as Transport>::Error: 'static,
pub fn and_then<C, F, O>(self, f: C) -> AndThen<Self, C> where
C: FnOnce(Self::Output, ConnectedPoint) -> F + Clone,
F: TryFuture<Ok = O>,
<F as TryFuture>::Error: Error,
<F as TryFuture>::Error: 'static,
[src]
C: FnOnce(Self::Output, ConnectedPoint) -> F + Clone,
F: TryFuture<Ok = O>,
<F as TryFuture>::Error: Error,
<F as TryFuture>::Error: 'static,
pub fn upgrade(self, version: Version) -> Builder<Self> where
Self::Error: 'static,
[src]
Self::Error: 'static,
Auto Trait Implementations
impl<T> !RefUnwindSafe for RelayTransport<T>
impl<T> Send for RelayTransport<T> where
T: Send,
T: Send,
impl<T> Sync for RelayTransport<T> where
T: Sync,
T: Sync,
impl<T> Unpin for RelayTransport<T> where
T: Unpin,
T: Unpin,
impl<T> !UnwindSafe for RelayTransport<T>
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> Same<T> for T
type Output = T
Should always be Self
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
pub fn to_owned(&self) -> T
[src]
pub fn clone_into(&self, target: &mut T)
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,