Struct PeerGroup 

pub struct PeerGroup { /* private fields */ }

Implementations

impl PeerGroup

pub fn get_peer_by_hash(&self, hash: &Hash) -> Option<Peer>

impl PeerGroup

pub fn get_rtt_cap_ms(&self) -> u64

impl PeerGroup

pub fn has_peer(&self, peer: &Peer) -> bool

impl PeerGroup

pub fn init(net: ScatterNet, config: PeerGroupConfig) -> Result<Self>

impl PeerGroup

pub fn insert_peer(&self, peer: Peer)

Inserts a Peer into this PeerGroup

impl PeerGroup

pub fn is_open(&self) -> bool

impl PeerGroup

pub fn from_inner( readonly: PeerGroupInnerReadonly, writable: PeerGroupInnerWritable, ) -> Self

impl PeerGroup

pub const fn from_inner_rwt( inner: RWT<PeerGroupInnerReadonly, PeerGroupInnerWritable>, ) -> Self

impl PeerGroup

pub fn sort_peers<F>(&self, compare: F) -> Vec<Peer>

where F: FnMut(&Peer, &Peer) -> Ordering,

Methods from Deref<Target = RWT<PeerGroupInnerReadonly, PeerGroupInnerWritable>>

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 PeerGroup

type Chunk = OwnedDataChunk

type Error = PeerGroupAsyncStoreError

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 PeerGroup

fn clone(&self) -> PeerGroup

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PeerGroup

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

Formats the value using the given formatter.

impl Deref for PeerGroup

type Target = RWT<PeerGroupInnerReadonly, PeerGroupInnerWritable>

The resulting type after dereferencing.

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

Dereferences the value.

impl Display for PeerGroup

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

Formats the value using the given formatter.

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

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

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