Struct ComponentHost

pub struct ComponentHost { /* private fields */ }

A Wick Host wraps a Wick runtime with server functionality like persistence,.

Implementations

impl ComponentHost

pub async fn start(&mut self, seed: Option<u64>) -> Result<(), HostError>

Starts the host. This call is non-blocking, so it is up to the consumer to wait with a method like host.wait_for_sigint().

pub fn rpc_address(&self) -> Option<SocketAddr>

Get the address the host’s RPC server is bound to.

pub const fn get_server_info(&self) -> &Option<ServerState>

pub async fn stop(self)

Stops a running host.

pub fn get_runtime(&self) -> Result<&Runtime, HostError>

pub fn get_runtime_uid(&self) -> Result<Uuid, HostError>

pub async fn start_runtime( &mut self, seed: Option<Seed>, ) -> Result<(), HostError>

pub async fn wait_for_sigint(&self) -> Result<(), HostError>

pub fn get_host_id(&self) -> &str

pub const fn is_started(&self) -> bool

pub fn render_dotviz(&self, op: &str) -> Result<String, HostError>

Trait Implementations

impl Debug for ComponentHost

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

Formats the value using the given formatter.

impl Host for ComponentHost

fn namespace(&self) -> &str

fn get_signature( &self, path: Option<&[&str]>, entity: Option<&Entity>, ) -> Result<ComponentSignature, HostError>

fn invoke<'life0, 'async_trait>( &'life0 self, invocation: Invocation, data: Option<RuntimeConfig>, ) -> Pin<Box<dyn Future<Output = Result<PacketStream, HostError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn invoke_deep<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, path: Option<&'life1 [&'life2 str]>, invocation: Invocation, data: Option<RuntimeConfig>, ) -> Pin<Box<dyn Future<Output = Result<PacketStream, HostError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn get_active_config(&self) -> WickConfiguration