Struct Host 

pub struct Host {
    pub stop_tx: Sender<Option<Instant>>,
    pub stop_rx: Receiver<Option<Instant>>,
    /* private fields */
}

wasmCloud Host Represents the core host structure for managing components, providers, links, and other functionalities in a wasmCloud host environment.

Fields

stop_tx: Sender<Option<Instant>>

A channel to send a stop event to the host, signaling it to shut down.

stop_rx: Receiver<Option<Instant>>

A channel to receive a stop event from the host, signaling it to shut down.

Implementations

impl Host

pub fn builder() -> HostBuilder

Create a new HostBuilder

pub async fn stopped(&self) -> Result<Option<Instant>>

Waits for host to be stopped via lattice commands and returns the shutdown deadline on success

Errors

Returns an error if internal stop channel is closed prematurely

pub fn id(&self) -> String

Returns the host’s unique identifier

pub fn lattice(&self) -> &str

Returns the lattice the host is running on

Trait Implementations

impl ControlInterfaceServer for Host

fn handle_link_put<'life0, 'async_trait>( &'life0 self, request: Link, ) -> Pin<Box<dyn Future<Output = Result<CtlResponse<()>>> + Send + 'async_trait>>

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

Handle a new link by modifying the relevant source crate::wasmbus::ComponentSpecification.

fn handle_link_del<'life0, 'async_trait>( &'life0 self, request: DeleteInterfaceLinkDefinitionRequest, ) -> Pin<Box<dyn Future<Output = Result<CtlResponse<()>>> + Send + 'async_trait>>

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

Remove an interface link on a source component for a specific package

fn handle_auction_component<'life0, 'async_trait>( &'life0 self, request: ComponentAuctionRequest, ) -> Pin<Box<dyn Future<Output = Result<Option<CtlResponse<ComponentAuctionAck>>>> + Send + 'async_trait>>

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

Handle an auction request for a component. This method should return Ok(None) if the host does not want to respond to the auction request.

fn handle_auction_provider<'life0, 'async_trait>( &'life0 self, request: ProviderAuctionRequest, ) -> Pin<Box<dyn Future<Output = Result<Option<CtlResponse<ProviderAuctionAck>>>> + Send + 'async_trait>>

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

Handle an auction request for a provider. This method should return Ok(None) if the host does not want to respond to the auction request.

fn handle_stop_host<'life0, 'async_trait>( &'life0 self, request: StopHostCommand, ) -> Pin<Box<dyn Future<Output = Result<CtlResponse<()>>> + Send + 'async_trait>>

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

Handle a request to stop the host. This method should return a response indicating success or failure.

fn handle_scale_component<'async_trait>( self: Arc<Self>, request: ScaleComponentCommand, ) -> Pin<Box<dyn Future<Output = Result<CtlResponse<()>>> + Send + 'async_trait>>

where Self: 'async_trait,

Handle a request to scale a component. This method should return a response indicating success or failure.

fn handle_update_component<'async_trait>( self: Arc<Self>, request: UpdateComponentCommand, ) -> Pin<Box<dyn Future<Output = Result<CtlResponse<()>>> + Send + 'async_trait>>

where Self: 'async_trait,

Handle a request to update a component. This method should return a response indicating success or failure.

fn handle_start_provider<'async_trait>( self: Arc<Self>, request: StartProviderCommand, ) -> Pin<Box<dyn Future<Output = Result<Option<CtlResponse<()>>>> + Send + 'async_trait>>

where Self: 'async_trait,

Handle a request to start a provider. This method should return a response indicating success or failure.

fn handle_stop_provider<'life0, 'async_trait>( &'life0 self, request: StopProviderCommand, ) -> Pin<Box<dyn Future<Output = Result<CtlResponse<()>>> + Send + 'async_trait>>

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

Handle a request to stop a provider. This method should return a response indicating success or failure.

fn handle_inventory<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<CtlResponse<HostInventory>>> + Send + 'async_trait>>

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

Handle a request to get the host inventory. This method should return a response containing the host inventory.

fn handle_claims<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<CtlResponse<Vec<HashMap<String, String>>>>> + Send + 'async_trait>>

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

Handle a request to get the claims for all components and providers. This method should return a response containing the claims.

fn handle_links<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<u8>>> + Send + 'async_trait>>

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

Handle a request to get the links for all components. This method should return a response containing the links.

fn handle_config_get<'life0, 'life1, 'async_trait>( &'life0 self, config_name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<u8>>> + Send + 'async_trait>>

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

Handle a request to get the configuration for a specific key. This method should return a response containing the configuration.

fn handle_config_delete<'life0, 'life1, 'async_trait>( &'life0 self, config_name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<CtlResponse<()>>> + Send + 'async_trait>>

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

Handle a request to delete the configuration for a specific key. This method should return a response indicating success or failure.

fn handle_label_put<'life0, 'life1, 'async_trait>( &'life0 self, request: HostLabel, host_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<CtlResponse<()>>> + Send + 'async_trait>>

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

Handle a request to put a label on the host. This method should return a response indicating success or failure.

fn handle_label_del<'life0, 'life1, 'async_trait>( &'life0 self, request: HostLabelIdentifier, host_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<CtlResponse<()>>> + Send + 'async_trait>>

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

Handle a request to delete a label from the host. This method should return a response indicating success or failure.

fn handle_registries_put<'life0, 'async_trait>( &'life0 self, request: HashMap<String, RegistryCredential>, ) -> Pin<Box<dyn Future<Output = Result<CtlResponse<()>>> + Send + 'async_trait>>

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

Handle a request to put registry credentials. This method should return a response indicating success or failure.

fn handle_config_put<'life0, 'life1, 'async_trait>( &'life0 self, config_name: &'life1 str, data: Bytes, ) -> Pin<Box<dyn Future<Output = Result<CtlResponse<()>>> + Send + 'async_trait>>

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

Handle a request to put configuration data. This method should return a response indicating success or failure.

fn handle_ping_hosts<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<CtlResponse<Host>>> + Send + 'async_trait>>

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

Handle a request to ping all hosts in the lattice. This method should return a response containing the host data.