Struct Swarm 

pub struct Swarm { /* private fields */ }

The transport and dht management.

Implementations

impl Swarm

pub fn did(&self) -> Did

Get did of self.

pub fn account_pubkey(&self) -> Result<PublicKey<33>, Error>

Get the local account public key used for E2E public-key negotiation.

pub fn dht(&self) -> Arc<PeerRing>

Get DHT(Distributed Hash Table) of self.

pub fn set_callback( &self, callback: Arc<dyn SwarmCallback + Send + Sync>, ) -> Result<(), Error>

Set callback for swarm.

pub fn stabilizer(&self) -> Stabilizer

Create Stabilizer for swarm.

pub async fn disconnect(&self, peer: Did) -> Result<(), Error>

Disconnect a connection. There are three steps:

1. remove from DHT;
2. remove from Transport;
3. close the connection;

pub async fn connect(&self, peer: Did) -> Result<(), Error>

Connect a given Did. If the did is already connected, return directly, else try prepare offer and establish connection by dht. This function may returns a pending connection or connected connection.

pub async fn send_message( &self, msg: Message, destination: Did, ) -> Result<Uuid, Error>

Send Message to peer.

pub fn peers(&self) -> Vec<ConnectionInspect>

List peers and their connection status.

pub async fn inspect(&self) -> SwarmInspect

Check the status of swarm

impl Swarm

pub async fn create_offer(&self, peer: Did) -> Result<MessagePayload, Error>

Create new connection and its answer. This function will wrap the offer inside a payload with verification.

pub async fn answer_offer( &self, offer_payload: MessagePayload, ) -> Result<MessagePayload, Error>

Answer the offer of remote connection. This function will verify the answer payload and will wrap the answer inside a payload with verification.

pub async fn accept_answer( &self, answer_payload: MessagePayload, ) -> Result<(), Error>

Accept the answer of remote connection. This function will verify the answer payload and will return its did with the connection.

Trait Implementations

impl<const REDUNDANT: u16> ChordStorageInterface<REDUNDANT> for Swarm

fn storage_fetch<'life0, 'async_trait>( &'life0 self, entry_key: Did, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, Swarm: 'async_trait,

Fetch an entry. If it exists in local storage, copy it to the cache; otherwise query the responsible remote node.

fn storage_store<'life0, 'async_trait>( &'life0 self, entry: Entry, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, Swarm: 'async_trait,

Store Entry, TryInto<Entry> is implemented for alot of types

fn storage_append_data<'life0, 'life1, 'async_trait>( &'life0 self, topic: &'life1 str, data: Encoded, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Swarm: 'async_trait,

Append data to a Data kind entry.

fn storage_touch_data<'life0, 'life1, 'async_trait>( &'life0 self, topic: &'life1 str, data: Encoded, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Swarm: 'async_trait,

Append data to a Data kind entry uniquely.

impl ChordStorageInterfaceCacheChecker for Swarm

fn storage_check_cache<'life0, 'async_trait>( &'life0 self, entry_key: Did, ) -> Pin<Box<dyn Future<Output = Option<Entry>> + Send + 'async_trait>>

where 'life0: 'async_trait, Swarm: 'async_trait,

Check local cache

impl<const REDUNDANT: u16> SubringInterface<REDUNDANT> for Swarm

fn subring_join<'life0, 'life1, 'async_trait>( &'life0 self, name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Swarm: 'async_trait,

add did into current chord subring. send direct message with JoinSubring type, which will handled by next node.