Struct NatsProvider

pub struct NatsProvider { /* private fields */ }

NATS implementation of the wasmcloud:messaging specification

Implementations

impl NatsProvider

pub fn new() -> NatsProvider

Creates a new NATS provider. This is either invoked manually in static plugin mode, or invoked by the host during dynamic loading

Trait Implementations

impl CapabilityProvider for NatsProvider

fn configure_dispatch( &self, dispatcher: Box<dyn Dispatcher>, ) -> Result<(), Box<dyn Error + Sync + Send>>

Receives a dispatcher from the host runtime

fn handle_call( &self, actor: &str, op: &str, msg: &[u8], ) -> Result<Vec<u8>, Box<dyn Error + Sync + Send>>

Handles an invocation received from the host runtime

fn stop(&self)

This function is called to let the capability provider know that it is being removed from the host runtime. This gives the provider an opportunity to clean up any resources and stop any running threads. WARNING: do not do anything in this function that can cause a panic, including attempting to write to STDOUT while the host process is terminating

impl Clone for NatsProvider

fn clone(&self) -> NatsProvider

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Default for NatsProvider

fn default() -> Self

Returns the “default value” for a type.