Struct Client 

pub struct Client { /* private fields */ }

NATS backend client for messaging, key-value, and blobstore.

Trait Implementations

impl Backend for Client

type ConnectOptions = ConnectOptions

The options used to connect to the backend.

async fn connect_with(options: Self::ConnectOptions) -> Result<Self>

Connect to the resource with the specified options.

fn connect() -> impl Future<Output = Result<Self, Error>>

Connect to the resource.

impl Client for Client

fn subscribe(&self) -> FutureResult<Subscriptions>

Subscribe to messages.

fn send(&self, topic: String, message: MessageProxy) -> FutureResult<()>

Send a message to a topic.

fn request( &self, topic: String, message: MessageProxy, options: Option<RequestOptions>, ) -> FutureResult<MessageProxy>

Request a response from a topic.

impl Clone for Client

fn clone(&self) -> Client

Returns a duplicate 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.

impl WasiBlobstoreCtx for Client

wasi-blobstore implementation backed by NATS JetStream object store.

fn create_container(&self, name: String) -> FutureResult<Arc<dyn Container>>

Open a container.

fn get_container(&self, name: String) -> FutureResult<Arc<dyn Container>>

Get a container.

fn delete_container(&self, name: String) -> FutureResult<()>

Delete a container.

fn container_exists(&self, name: String) -> FutureResult<bool>

Check if a container exists.

impl WasiKeyValueCtx for Client

wasi-keyvalue implementation backed by NATS JetStream KV store.

fn open_bucket(&self, identifier: String) -> FutureResult<Arc<dyn Bucket>>

Open a bucket.

impl WasiMessagingCtx for Client

wasi-messaging implementation backed by NATS.

fn connect(&self) -> FutureResult<Arc<dyn Client>>

Connect to the messaging system and return a client proxy.

fn new_message(&self, data: Vec<u8>) -> Result<Arc<dyn Message>>

Create a new message with the given payload.

fn set_content_type( &self, message: Arc<dyn Message>, content_type: String, ) -> Result<Arc<dyn Message>>

Set the content-type on a message.

fn set_payload( &self, message: Arc<dyn Message>, data: Vec<u8>, ) -> Result<Arc<dyn Message>>

Set the payload on a message.

fn add_metadata( &self, message: Arc<dyn Message>, key: String, value: String, ) -> Result<Arc<dyn Message>>

Append a key-value pair to the metadata of a message.

fn set_metadata( &self, message: Arc<dyn Message>, metadata: Metadata, ) -> Result<Arc<dyn Message>>

Set all the metadata on a message.

fn remove_metadata( &self, message: Arc<dyn Message>, key: String, ) -> Result<Arc<dyn Message>>

Remove a key-value pair from the metadata of a message.