Struct mpc_relay_client::Client

pub struct Client { /* private fields */ }

Relay service websocket client.

Implementations

impl NativeClient

pub async fn new( server: &str, options: ClientOptions ) -> impl Future<Output = Result<(NativeClient, EventLoop<Message, Error, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, SplitSink<WebSocketStream<MaybeTlsStream<TcpStream>>, Message>>), Error>>

Create a new native client.

Trait Implementations

impl Clone for NativeClient

fn clone(&self) -> NativeClient

Returns a copy of the value.

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

Performs copy-assignment from source.

impl From<NativeClient> for Transport

fn from(value: NativeClient) -> Transport

Converts to this type from the input type.

impl NetworkTransport for NativeClient

fn public_key(&self) -> &[u8]

The public key for this client.

fn connect<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait, Global>>where 'life0: 'async_trait, NativeClient: 'async_trait,

Perform initial handshake with the server.

fn connect_peer<'life0, 'life1, 'async_trait>( &'life0 mut self, public_key: &'life1 [u8] ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait, Global>>where 'life0: 'async_trait, 'life1: 'async_trait, NativeClient: 'async_trait,

Handshake with a peer.

Peer already exists error is returned if this client is already connecting to the peer.

fn send_json<'life0, 'life1, 'life2, 'async_trait, S>( &'life0 mut self, public_key: &'life1 [u8], payload: &'life2 S, session_id: Option<Uuid> ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait, Global>>where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, S: Serialize + Send + Sync + 'async_trait + ?Sized, NativeClient: 'async_trait,

Send a JSON message to a peer via the relay service.

fn send_blob<'life0, 'life1, 'async_trait>( &'life0 mut self, public_key: &'life1 [u8], payload: Vec<u8, Global>, session_id: Option<Uuid> ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait, Global>>where 'life0: 'async_trait, 'life1: 'async_trait, NativeClient: 'async_trait,

Send a binary message to a peer via the relay service.

fn new_session<'life0, 'async_trait>( &'life0 mut self, participant_keys: Vec<Vec<u8, Global>, Global>, session_id: Option<Uuid> ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait, Global>>where 'life0: 'async_trait, NativeClient: 'async_trait,

Create a new session.

fn register_connection<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, session_id: &'life1 Uuid, peer_key: &'life2 [u8] ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait, Global>>where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, NativeClient: 'async_trait,

Register a peer connection in a session.

fn close_session<'life0, 'async_trait>( &'life0 mut self, session_id: Uuid ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait, Global>>where 'life0: 'async_trait, NativeClient: 'async_trait,

Close a session.

fn broadcast_json<'life0, 'life1, 'life2, 'life3, 'async_trait, S>( &'life0 mut self, session_id: &'life1 Uuid, recipient_public_keys: &'life2 [Vec<u8, Global>], payload: &'life3 S ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait, Global>>where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, S: Serialize + Send + Sync + 'async_trait + ?Sized, NativeClient: 'async_trait,

Broadcast a JSON message in the context of a session.

fn broadcast_blob<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, session_id: &'life1 Uuid, recipient_public_keys: &'life2 [Vec<u8, Global>], payload: Vec<u8, Global> ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait, Global>>where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, NativeClient: 'async_trait,

Broadcast a binary message in the context of a session.

fn close<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait, Global>>where 'life0: 'async_trait, NativeClient: 'async_trait,

Close the socket connection.