Struct wasmcloud_core::wrpc::Client

pub struct Client { /* private fields */ }

Wrapper around wrpc_transport_nats::Client that includes a async_nats::HeaderMap for passing invocation and trace context.

Implementations

impl Client

pub fn new( nats: impl Into<Arc<Client>>, lattice: &str, component_id: &str, headers: HeaderMap, timeout: Duration ) -> Self

Create a new wRPC Client with the given NATS client, lattice, component ID, and headers.

Arguments

• nats - The NATS client to use for communication.
• lattice - The lattice ID to use for communication.
• prefix - The component ID to use for communication.
• headers - The headers to include with each outbound invocation.

Trait Implementations

impl Client for Client

type Context = Option<HeaderMap>

type Subject = Subject

type Subscriber = Subscriber

type Transmission = Transmission

type Acceptor = AcceptorWithHeaders

type Invocation = InvocationWithHeaders

type InvocationStream<T> = Pin<Box<dyn Stream<Item = Result<AcceptedInvocation<Option<HeaderMap>, T, TransmitterWithHeaders>, Error>> + Send>>

async fn serve<T, S, Fut>( &self, instance: &str, name: &str, svc: S ) -> Result<Self::InvocationStream<T>>

where S: Service<IncomingInvocation<Option<HeaderMap>, Subscriber, AcceptorWithHeaders>, Future = Fut> + Send + Clone + 'static, Fut: Future<Output = Result<AcceptedInvocation<Option<HeaderMap>, T, TransmitterWithHeaders>>> + Send,

Serve function name from instance instance

fn new_invocation( &self ) -> OutgoingInvocation<Self::Invocation, Self::Subscriber, Self::Subject>

Constructs a new invocation to be sent to peer

fn serve_static<T>( &self, instance: &str, name: &str ) -> impl Future<Output = Result<Self::InvocationStream<T>, Error>> + Send

where T: for<'a> Receive<'a> + Subscribe + 'static,

Serve function name from instance instance with statically-typed parameter type T.

fn serve_dynamic( &self, instance: &str, name: &str, params: Arc<[Type]> ) -> impl Future<Output = Result<Self::InvocationStream<Vec<Value>>, Error>> + Send

Serve function name from instance instance with dynamically-typed parameter type params.

fn invoke_static<'a, T>( &self, instance: &str, name: &str, params: impl Encode ) -> impl Future<Output = Result<(T, Self::Transmission), Error>> + Send

where T: Receive<'a> + Subscribe + Send,

Invokes function name from instance instance with parameters params and statically-typed results of type T

fn invoke_dynamic( &self, instance: &str, name: &str, params: impl Encode, results: &[Type] ) -> impl Future<Output = Result<(Vec<Value>, Self::Transmission), Error>> + Send

Invokes function name from instance instance with parameters params and dynamically-typed results of type results

impl Clone for Client

fn clone(&self) -> Client

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Client

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.