[−][src]Struct splinter::network::Network
Methods
impl Network
[src]
pub fn new(
mesh: Mesh,
heartbeat_interval: u64
) -> Result<Self, NetworkStartUpError>
[src]
mesh: Mesh,
heartbeat_interval: u64
) -> Result<Self, NetworkStartUpError>
pub fn peer_ids(&self) -> Vec<String>
[src]
pub fn get_peer_endpoint(&self, peer_id: &str) -> Option<String>
[src]
pub fn get_peer_by_endpoint(&self, endpoint: &str) -> Option<String>
[src]
pub fn add_disconnect_listener(&self, listener: Box<dyn DisconnectListener>)
[src]
pub fn add_connection(
&self,
connection: Box<dyn Connection>
) -> Result<String, ConnectionError>
[src]
&self,
connection: Box<dyn Connection>
) -> Result<String, ConnectionError>
pub fn remove_connection(&self, peer_id: &str) -> Result<(), ConnectionError>
[src]
pub fn add_peer(
&self,
peer_id: String,
connection: Box<dyn Connection>
) -> Result<(), ConnectionError>
[src]
&self,
peer_id: String,
connection: Box<dyn Connection>
) -> Result<(), ConnectionError>
Adds a peer with a given id.
Note that while this peer id is specified explicitly, the connection will still require to complete the authorization handshake, at which point its node id that the remote connection has identified itself with may replace the given id.
pub fn update_peer_id(
&self,
old_id: String,
new_id: String
) -> Result<(), PeerUpdateError>
[src]
&self,
old_id: String,
new_id: String
) -> Result<(), PeerUpdateError>
pub fn send(&self, peer_id: &str, msg: &[u8]) -> Result<(), SendError>
[src]
pub fn recv(&self) -> Result<NetworkMessageWrapper, RecvError>
[src]
pub fn recv_timeout(
&self,
timeout: Duration
) -> Result<NetworkMessageWrapper, RecvTimeoutError>
[src]
&self,
timeout: Duration
) -> Result<NetworkMessageWrapper, RecvTimeoutError>
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for Network
impl Send for Network
impl !Sync for Network
impl Unpin for Network
impl !UnwindSafe for Network
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<'a, T> DefaultFeatures<'a> for T where
T: 'a + Clone + Send + Sync,
T: 'a + Clone + Send + Sync,
fn clone_boxed(&self) -> Box<dyn DefaultFeatures<'a> + 'a>
fn self_address_mut(&mut self) -> *mut ()
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> IntoSql for T
fn into_sql<T>(self) -> Self::Expression where
Self: AsExpression<T>,
Self: AsExpression<T>,
fn as_sql<'a, T>(&'a self) -> <&'a Self as AsExpression<T>>::Expression where
&'a Self: AsExpression<T>,
&'a Self: AsExpression<T>,
impl<'a, T> NonSyncFeatures<'a> for T where
T: 'a + Clone,
T: 'a + Clone,
fn clone_boxed(&self) -> Box<dyn NonSyncFeatures<'a> + 'a>
fn self_address_mut(&mut self) -> *mut ()
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> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
fn to_owned(&self) -> T
[src]
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.
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>,