Struct RpcClient 

pub struct RpcClient { /* private fields */ }

Implementations

impl RpcClient

pub async fn connect( endpoint: IpcEndpoint, config: FrameConfig, ) -> Result<Self, RuntimeError>

pub async fn connect_with_handshake_config( endpoint: IpcEndpoint, config: FrameConfig, handshake: RpcClientHandshakeConfig, ) -> Result<Self, RuntimeError>

pub async fn connect_with_configs( endpoint: IpcEndpoint, config: FrameConfig, handshake: RpcClientHandshakeConfig, notifications: RpcClientNotificationConfig, ) -> Result<Self, RuntimeError>

pub async fn from_connection<C>(connection: C) -> Result<Self, RuntimeError>

where C: Into<RpcConnection>,

pub async fn from_connection_with_handshake_config<C>( connection: C, handshake: RpcClientHandshakeConfig, ) -> Result<Self, RuntimeError>

where C: Into<RpcConnection>,

pub async fn from_connection_with_configs<C>( connection: C, handshake: RpcClientHandshakeConfig, notifications: RpcClientNotificationConfig, ) -> Result<Self, RuntimeError>

where C: Into<RpcConnection>,

pub async fn call( &self, instance_id: InstanceId, method_id: MethodId, payload: Value, ) -> Result<Value, RuntimeError>

pub async fn call_timeout( &self, instance_id: InstanceId, method_id: MethodId, payload: Value, timeout: Duration, ) -> Result<Value, RuntimeError>

pub async fn resolve_instance_ids( &self, names: Vec<String>, ) -> Result<Vec<u64>, RuntimeError>

pub async fn create_instance( &self, service_guid: ServiceGuid, create_payload: Option<Vec<u8>>, options: BTreeMap<String, String>, ) -> Result<InstanceId, RuntimeError>

pub async fn release_instance( &self, instance_id: InstanceId, ) -> Result<(), RuntimeError>

pub async fn list_instances( &self, service_guid: Option<ServiceGuid>, ) -> Result<Vec<InstanceDescriptor>, RuntimeError>

pub fn subscribe_notifications( &self, instance_id_filter: Option<InstanceId>, notification_id_filter: Option<u32>, ) -> RpcNotificationReceiver

pub async fn goodbye( &self, message: impl Into<String>, ) -> Result<(), RuntimeError>

Trait Implementations

impl Clone for RpcClient

fn clone(&self) -> RpcClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.