Struct NatsHostBuilder 

pub struct NatsHostBuilder { /* private fields */ }

Opinionated crate::wasmbus::HostBuilder that uses NATS as the primary transport and implementations for the crate::wasmbus::Host extension traits.

This builder is used to create a crate::wasmbus::HostBuilder and a NatsControlInterfaceServer for listening for control messages on the NATS message bus. Incoming messages will use the crate::wasmbus::ctl::ControlInterfaceServer trait to handle the messages and send them to the host.

Implementations

impl NatsHostBuilder

pub async fn new( ctl_nats: Client, ctl_topic_prefix: Option<String>, lattice: String, js_domain: Option<String>, oci_opts: Option<Config>, labels: BTreeMap<String, String>, config_service_enabled: bool, enable_component_auction: bool, enable_provider_auction: bool, ) -> Result<Self>

Initialize the host with the NATS control interface connection

pub async fn with_policy_manager( self, host_key: Arc<KeyPair>, labels: HashMap<String, String>, policy_topic: Option<String>, policy_timeout: Option<Duration>, policy_changes_topic: Option<String>, ) -> Result<Self>

Setup the NATS policy manager for the host

pub fn with_secrets_manager(self, secrets_topic_prefix: String) -> Result<Self>

Setup the NATS secrets manager for the host

pub fn with_event_publisher(self, source: String) -> Self

Setup the NATS event publisher for the host

This will create a new NATS event publisher with the provided source. It’s strongly recommended to use the host’s public key as the source, as this will allow tracing events back to the host that published them.

pub async fn build( self, config: WasmbusHostConfig, ) -> Result<(HostBuilder, NatsControlInterfaceServer)>

Build the HostBuilder with the NATS extension traits and the provided WasmbusHostConfig.