Struct ScatterNet 

pub struct ScatterNet { /* private fields */ }

Implementations

impl ScatterNet

pub async fn accept_loop(self)

impl ScatterNet

pub async fn connect_to( &self, node_id: NodeId, state: Option<PeerState>, ) -> Result<Peer>

impl ScatterNet

pub async fn fetch_blob( self, hkey: &Hkey, ) -> Result<SharedBuffer, ScatterNetFetchBlobError>

impl ScatterNet

pub fn fetch_encrypted_chunk( &self, hash: Arc<Hash>, ) -> ScatterNetFetchEncryptedChunk<'_>

impl ScatterNet

pub fn get_lake(&self) -> &DataLake<'_>

impl ScatterNet

pub fn get_node_id(&self) -> NodeId

impl ScatterNet

pub fn get_peer_groups(&self) -> Vec<PeerGroup>

impl ScatterNet

pub fn get_state(&self) -> Result<NetState>

impl ScatterNet

pub async fn handle_incoming_connection( self, incoming: Incoming, ) -> Result<Peer>

impl ScatterNet

pub async fn init(config: NetConfig, state: NetState) -> Result<Self>

Initializes a ScatterNet instance.

Errors

An Error is returned if binding the socket fails.

impl ScatterNet

pub fn init_peer( &self, connection: Connection, state: Option<PeerState>, ) -> Result<Peer>

impl ScatterNet

pub fn init_peer_groups(&self, configs: Vec<PeerGroupConfig>) -> Result<()>

impl ScatterNet

pub fn accept_connection( &self, connection: Connection, ) -> Result<Peer, ScatterNetAcceptConnectionError>

Accepts the Connection and returns the Peer.

Errors

• ScatterNetAcceptConnectionError::RemoteNodeId means the Connection’s NodeId couldn’t be resolved.

impl ScatterNet

pub fn export_config(&self) -> NetConfig

impl ScatterNet

pub fn export_state(&self) -> NetState

impl ScatterNet

pub fn from_inner( readonly: ScatterNetInnerReadonly, writable: ScatterNetInnerWritable, ) -> Self

impl ScatterNet

pub const fn from_inner_rwt( inner: RWT<ScatterNetInnerReadonly, ScatterNetInnerWritable>, ) -> Self

impl ScatterNet

pub fn get_peer(&self, node_id: &NodeId) -> Option<Peer>

impl ScatterNet

pub fn known_peers(&self) -> Vec<Peer>

impl ScatterNet

pub fn put_blob(&self, data: Bytes) -> Promise<Hkey, ScatterNetAsyncStoreError>

Methods from Deref<Target = RWT<ScatterNetInnerReadonly, ScatterNetInnerWritable>>

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 ScatterNet

type Chunk = OwnedDataChunk

type Error = ScatterNetAsyncStoreError

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 ScatterNet

fn clone(&self) -> ScatterNet

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ScatterNet

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

Formats the value using the given formatter.

impl Deref for ScatterNet

type Target = RWT<ScatterNetInnerReadonly, ScatterNetInnerWritable>

The resulting type after dereferencing.

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

Dereferences the value.

impl ProtocolHandler for ScatterNet

async fn accept(&self, connection: Connection) -> Result<(), AcceptError>

Handle an incoming connection.

fn on_connecting( &self, connecting: Connecting, ) -> impl Future<Output = Result<Connection, AcceptError>> + Send

Optional interception point to handle the Connecting state.

fn shutdown(&self) -> impl Future<Output = ()> + Send

Called when the router shuts down.

impl Store for ScatterNet

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

Attempts to get the DataChunk locally.

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

Fails if storing the chunk locally fails.

type Chunk<'c> = MbufDataChunk<'c>

type Error = ScatterNetStoreError

fn put(&self, data: &[u8]) -> Result<Hkey, Self::Error>

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

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

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