Struct CrpcSnapControlClient 

pub struct CrpcSnapControlClient { /* private fields */ }

Connect RPC client for the SNAP control plane API.

Implementations

impl CrpcSnapControlClient

pub fn new(base_url: &Url) -> Result<Self>

Creates a new client with default settings

pub fn new_with_client(base_url: &Url, client: Client) -> Result<Self>

Creates a new client with the provided reqwest::Client.

pub fn use_token_source( &mut self, token_source: Arc<dyn TokenSource>, ) -> &mut Self

Uses the provided token source for authentication.

Methods from Deref<Target = CrpcClient>

pub async fn unary_request<Req, Res>( &self, path: &str, req: Req, ) -> Result<Res, CrpcClientError>

where Req: Message + Default, Res: Message + Default,

Unary RPC request.

Trait Implementations

impl ControlPlaneApi for CrpcSnapControlClient

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

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

Get the SNAP data plane address.

fn register_snaptun_identity<'life0, 'async_trait>( &'life0 self, initiator_identity: PublicKey, psk_share: Option<[u8; 32]>, ) -> Pin<Box<dyn Future<Output = Result<Option<[u8; 32]>, CrpcClientError>> + Send + 'async_trait>>

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

Register a static identity for a snaptun connection.

impl Deref for CrpcSnapControlClient

type Target = CrpcEndhostApiClient

The resulting type after dereferencing.

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

Dereferences the value.

impl SnapTunControlPlaneClient for CrpcSnapControlClient

fn register_identity<'life0, 'async_trait>( &'life0 self, initiator_identity: PublicKey, psk_share: Option<[u8; 32]>, ) -> Pin<Box<dyn Future<Output = Result<Option<[u8; 32]>, CrpcClientError>> + Send + 'async_trait>>

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

Register an identity with the control plane.

fn register_identity_with_retries<'life0, 'async_trait>( &'life0 self, identity: PublicKey, psk_share: Option<[u8; 32]>, backoff: ExponentialBackoff, max_attempts: u32, ) -> Pin<Box<dyn Future<Output = Result<Option<[u8; 32]>, CrpcClientError>> + Send + 'async_trait>>

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

Register an identity with the control plane with retries.