Struct Peer 

pub struct Peer { /* private fields */ }

Implementations

impl Peer

pub async fn begin_interaction( self, ) -> Result<Interaction, PeerBeginInteractionError>

impl Peer

pub async fn fetch_blob( self, hkey: Hkey, ) -> Result<Option<FetchResponse>, PeerFetchBlobError>

impl Peer

pub fn get_state(&self) -> PeerState

impl Peer

pub fn is_available(&self) -> bool

impl Peer

pub fn net(&self) -> &ScatterNet

impl Peer

pub fn node_id(&self) -> NodeId

impl Peer

pub async fn ping( self, timeout_duration: Duration, ) -> Result<TimeDelta, PeerPingError>

Sends a ping packet to the peer and measures the round-trip time.

Arguments

• timeout_duration - Maximum time to wait for a pong response

Returns

• Ok(TimeDelta) - Round-trip time
• Err(PeerPingError) - Various failure modes

impl Peer

pub fn put_blob(self, data: Bytes) -> PeerPutBlob

impl Peer

pub async fn select_peer_group( self, ) -> Result<PeerGroup, PeerSelectPeerGroupError>

Inserts this Peer into a PeerGroup, if it isn’t in one already.

impl Peer

pub fn send_datagram(&self, bytes: Bytes) -> Result<(), SendDatagramError>

impl Peer

pub fn builder(net: ScatterNet, node_addr: impl Into<NodeAddr>) -> PeerBuilder

impl Peer

pub fn from_inner( readonly: PeerInnerReadonly, writable: PeerInnerWritable, ) -> Self

impl Peer

pub const fn from_inner_rwt( inner: RWT<PeerInnerReadonly, PeerInnerWritable>, ) -> Self

impl Peer

pub fn init(&self)

impl Peer

pub fn listen(self, connection: Connection)

impl Peer

pub fn replace_connection(&self, connection: Connection)

Replaces the connection to this Peer, and re-runs init.

Methods from Deref<Target = RWT<PeerInnerReadonly, PeerInnerWritable>>

pub fn read(&self) -> RwLockReadGuard<'_, RawRwLock, W>

pub fn try_read(&self) -> Option<RwLockReadGuard<'_, RawRwLock, W>>

pub fn try_write(&self) -> Option<RwLockWriteGuard<'_, RawRwLock, W>>

pub fn write(&self) -> RwLockWriteGuard<'_, RawRwLock, W>

Trait Implementations

impl AsyncStore for Peer

type Chunk = OwnedDataChunk

type Error = PeerAsyncStoreError

fn get(&self, hash: &Hash) -> Promise<Self::Chunk, Self::Error>

fn put_encrypted<C: DataChunk>(&self, chunk: C) -> Promise<(), Self::Error>

fn put(&self, data: Bytes) -> Promise<Hkey, Self::Error>

impl Clone for Peer

fn clone(&self) -> Peer

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Peer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Deref for Peer

type Target = RWT<PeerInnerReadonly, PeerInnerWritable>

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl Display for Peer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<E, R> Terminate<E, R> for Peer

where E: Into<VarInt> + Send, R: AsRef<[u8]> + Send,

fn terminate(&self, error_code: E, reason: &R)