Struct WebSocketClient 

pub struct WebSocketClient { /* private fields */ }

WebSocket client transport implementation

Implementations

impl WebSocketClient

pub fn new(config: WebSocketClientConfig, replica_id: ReplicaId) -> Self

Create a new WebSocket client

pub fn with_url(url: String, replica_id: ReplicaId) -> Self

Create a new client with default configuration

pub async fn connection_state(&self) -> ConnectionState

Get the current connection state

pub fn replica_id(&self) -> ReplicaId

Get the replica ID

pub async fn connect(&self) -> Result<(), WebSocketClientError>

Connect to the WebSocket server

pub async fn disconnect(&self) -> Result<(), WebSocketClientError>

Disconnect from the WebSocket server

pub async fn send_message( &self, message: SyncMessage, ) -> Result<(), WebSocketClientError>

Send a synchronization message

pub async fn send_raw(&self, data: &[u8]) -> Result<(), WebSocketClientError>

Send raw bytes

pub async fn receive_message( &self, ) -> Result<Option<SyncMessage>, WebSocketClientError>

Receive a synchronization message

pub async fn is_connected(&self) -> bool

Check if connected

Trait Implementations

impl Clone for WebSocketClient

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl SyncTransport for WebSocketClient

type Error = TransportError

fn send<'a>( &'a self, data: &'a [u8], ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'a>>

Send data to remote peers

fn receive( &self, ) -> Pin<Box<dyn Future<Output = Result<Vec<Vec<u8>>, Self::Error>> + Send + '_>>

Receive data from remote peers

fn is_connected(&self) -> bool

Check if transport is connected