Struct wasmbus_rpc::RpcClient

pub struct RpcClient { /* fields omitted */ }

Send wasmbus rpc messages

The primary use of RpcClient is providers sending to actors, however providers don’t need to construct this - one is created by HostBridge, which providers create during initialization.

This class is also used by wash and test tools for sending rpc messages to actors and providers. Note that sending to a provider requires an existing link definition, and, the message needs to be signed by a valid cluster key.

This RpcClient does not subscribe to rpc topics. To subscribe, use the nats client api directly.

Implementations

impl RpcClient

pub fn new(nats: Arc<NatsClient>, lattice_prefix: &str, key: KeyPair) -> Self

Constructs a new RpcClient for the async nats connection. parameters: async nats client, lattice rpc prefix (usually “default”), and secret key for signing messages

pub fn new_asynk(nats: Connection, lattice_prefix: &str, key: KeyPair) -> Self

Constructs a new RpcClient for a nats::asynk connection. parameters: async nats client, lattice rpc prefix (usually “default”), and secret key for signing messages

pub fn get_async(&self) -> Option<&NatsClient>

pub fn get_asynk(&self) -> Option<&Connection>

pub async fn send_json<Target, Arg, Resp>(
    &self,
    origin: WasmCloudEntity,
    target: Target,
    method: &str,
    data: JsonValue
) -> Result<JsonValue, RpcError> where
    Arg: DeserializeOwned + Serialize,
    Resp: DeserializeOwned + Serialize,
    Target: Into<WasmCloudEntity>, 

Send an rpc message using json-encoded data

pub async fn send<Target>(
    &self,
    origin: WasmCloudEntity,
    target: Target,
    message: Message<'_>
) -> Result<Vec<u8>, RpcError> where
    Target: Into<WasmCloudEntity>, 

Send an rpc message. target may be &str or String for sending to an actor, or a WasmCloudEntity (for actor or provider) If nats client is sync, this can block the current thread

pub async fn request(
    &self,
    subject: &str,
    data: &[u8]
) -> Result<Vec<u8>, RpcError>

Send nats request wait for response. If client is sync, this can block the current thread

pub async fn publish(&self, subject: &str, data: &[u8]) -> Result<(), RpcError>

Send nats message with no reply-to

Trait Implementations

impl Clone for RpcClient

fn clone(&self) -> RpcClient

Returns a copy of the value.

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

Performs copy-assignment from source.