[−][src]Struct tari_comms::CommsNode
CommsNode is a handle to a comms node.
It allows communication with the internals of tari_comms. Note that if this handle is dropped, tari_comms will shut down.
Implementations
impl CommsNode
[src]
pub fn subscribe_connection_manager_events(
&self
) -> Receiver<Arc<ConnectionManagerEvent>>
[src]
&self
) -> Receiver<Arc<ConnectionManagerEvent>>
Get a subscription to ConnectionManagerEvent
s
pub fn subscribe_connectivity_events(&self) -> ConnectivityEventRx
[src]
Get a subscription to ConnectivityEvent
s
pub fn subscribe_messaging_events(&self) -> MessagingEventReceiver
[src]
Return a subscription to OMS events. This will emit events sent after this subscription was created.
pub fn peer_manager(&self) -> Arc<PeerManager>
[src]
Return a cloned atomic reference of the PeerManager
pub fn node_identity(&self) -> Arc<NodeIdentity>
[src]
Return a cloned atomic reference of the NodeIdentity
pub fn node_identity_ref(&self) -> &NodeIdentity
[src]
Return a reference to the NodeIdentity
pub fn listening_address(&self) -> &Multiaddr
[src]
Return the Ip/Tcp address that this node is listening on
pub fn hidden_service(&self) -> Option<&HiddenService>
[src]
Return the Ip/Tcp address that this node is listening on
pub fn connection_manager(&self) -> ConnectionManagerRequester
[src]
Return an owned copy of a ConnectionManagerRequester. Used to initiate connections to peers.
pub fn connectivity(&self) -> ConnectivityRequester
[src]
Return an owned copy of a ConnectivityRequester. This is the async interface to the ConnectivityManager
pub fn shutdown_signal(&self) -> ShutdownSignal
[src]
Returns a new ShutdownSignal
pub fn shutdown(self) -> CommsShutdown
[src]
Shuts comms down. The object is consumed to ensure that no handles/channels are kept after shutdown
Auto Trait Implementations
impl !RefUnwindSafe for CommsNode
impl Send for CommsNode
impl Sync for CommsNode
impl Unpin for CommsNode
impl !UnwindSafe for CommsNode
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,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T, U> Cast<U> for T where
U: FromCast<T>,
U: FromCast<T>,
fn cast(self) -> U
impl<T> From<T> for T
[src]
impl<T> FromBits<T> for T
fn from_bits(t: T) -> T
impl<T> FromCast<T> for T
fn from_cast(t: T) -> T
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T, U> IntoBits<U> for T where
U: FromBits<T>,
U: FromBits<T>,
fn into_bits(self) -> U
impl<T> SafeBorrow<T> for T where
T: ?Sized,
T: ?Sized,
fn borrow_replacement(ptr: &T) -> &T
impl<T> Same<T> for T
type Output = T
Should always be Self
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.
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.
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>,