Struct wascc_nats::NatsProvider

pub struct NatsProvider { /* fields omitted */ }

NATS implementation of the wascc: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

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

Receives a dispatcher from the host runtime

pub 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

pub 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

impl Clone for NatsProvider

pub fn clone(&self) -> NatsProvider

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Default for NatsProvider

pub fn default() -> Self

Returns the "default value" for a type.