Struct AsyncSecureChannel

pub struct AsyncSecureChannel { /* private fields */ }

Wrapper around an open secure channel

Implementations

impl AsyncSecureChannel

pub fn request_handle(&self) -> IntegerId

Get the next request handle on the channel.

impl AsyncSecureChannel

pub fn new( certificate_store: Arc<RwLock<CertificateStore>>, session_info: SessionInfo, session_retry_policy: SessionRetryPolicy, ignore_clock_skew: bool, auth_token: Arc<ArcSwap<NodeId>>, transport_config: TransportConfiguration, connector: Box<dyn Connector>, channel_lifetime: u32, encoding_context: Arc<RwLock<ContextOwned>>, ) -> Self

Create a new client secure channel.

pub async fn send( &self, request: impl Into<RequestMessage>, timeout: Duration, ) -> Result<ResponseMessage, StatusCode>

Send a message on the secure channel, and wait for a response.

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

Attempt to establish a connection using this channel, returning an event loop for polling the connection.

pub async fn connect_no_retry( &self, ) -> Result<SecureChannelEventLoop, StatusCode>

Connect to the server without attempting to retry if it fails.

pub async fn close_channel(&self)

Close the secure channel, optionally wait for the channel to close.