Struct DefaultProxyClient 

pub struct DefaultProxyClient { /* private fields */ }

Default implementation using ProxyProtocolClient from ap-proxy

Implementations

impl DefaultProxyClient

pub fn new(config: ProxyClientConfig) -> Self

Trait Implementations

impl ProxyClient for DefaultProxyClient

fn connect<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<UnboundedReceiver<IncomingMessage>, RemoteClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Connect to the proxy server, returning a receiver for incoming messages

fn request_rendezvous<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), RemoteClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Request a rendezvous code from the proxy server

fn request_identity<'life0, 'async_trait>( &'life0 self, code: RendezvousCode, ) -> Pin<Box<dyn Future<Output = Result<(), RemoteClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Request the identity associated with a rendezvous code

fn send_to<'life0, 'async_trait>( &'life0 self, fingerprint: IdentityFingerprint, data: Vec<u8>, ) -> Pin<Box<dyn Future<Output = Result<(), RemoteClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Send a message to a peer by their fingerprint

fn disconnect<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<(), RemoteClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Disconnect from the proxy server