Struct RpcEndpoint 

pub struct RpcEndpoint { /* private fields */ }

RPC Endpoint (replacing Java’s RpcEndPoint)

Implementations

impl RpcEndpoint

pub async fn connect(host: String, port: u16) -> Result<Self>

Create and connect to the remote endpoint

pub async fn sync_call( &self, method: Bytes, body: Bytes, timeout_ms: u64, ) -> Result<Bytes>

Synchronous RPC call

pub async fn notify_call(&self, method: Bytes, body: Bytes) -> Result<()>

Asynchronous RPC call (fire and forget)

pub fn address(&self) -> String

Get endpoint address

pub fn host(&self) -> &str

pub fn port(&self) -> u16

Trait Implementations

impl Clone for RpcEndpoint

fn clone(&self) -> RpcEndpoint

Returns a duplicate of the value.

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

Performs copy-assignment from source.