Struct WadmProvider 

pub struct WadmProvider { /* private fields */ }

Implementations

impl WadmProvider

pub async fn run() -> Result<()>

pub fn from_host_data(host_data: &HostData) -> WadmProvider

Build a WadmProvider from HostData

Trait Implementations

impl Clone for WadmProvider

fn clone(&self) -> WadmProvider

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for WadmProvider

fn default() -> Self

Returns the “default value” for a type.

impl Handler<Option<Context>> for WadmProvider

async fn deploy_model( &self, ctx: Option<Context>, model_name: String, version: Option<String>, lattice: Option<String>, ) -> Result<Result<String, String>>

Deploys a model to the WADM system. If no lattice is provided, the default lattice name ‘default’ is used.

async fn undeploy_model( &self, ctx: Option<Context>, model_name: String, lattice: Option<String>, non_destructive: bool, ) -> Result<Result<(), String>>

Undeploys a model from the WADM system.

async fn put_model( &self, ctx: Option<Context>, model: String, lattice: Option<String>, ) -> Result<Result<(String, String), String>>

Stores the application manifest for later deploys. Model is the full YAML or JSON string in this case Returns the model name and version respectively.

async fn put_manifest( &self, ctx: Option<Context>, manifest: OamManifest, lattice: Option<String>, ) -> Result<Result<(String, String), String>>

Store an oam manifest directly for later deploys.

async fn get_model_history( &self, ctx: Option<Context>, model_name: String, lattice: Option<String>, ) -> Result<Result<Vec<VersionInfo>, String>>

Retrieves the history of a given model name.

async fn get_model_status( &self, ctx: Option<Context>, model_name: String, lattice: Option<String>, ) -> Result<Result<Status, String>>

Retrieves the status of a given model by name.

async fn get_model_details( &self, ctx: Option<Context>, model_name: String, version: Option<String>, lattice: Option<String>, ) -> Result<Result<OamManifest, String>>

Retrieves details on a given model.

async fn delete_model_version( &self, ctx: Option<Context>, model_name: String, version: Option<String>, lattice: Option<String>, ) -> Result<Result<bool, String>>

Deletes a model version from the WADM system.

async fn get_models( &self, ctx: Option<Context>, lattice: Option<String>, ) -> Result<Result<Vec<ModelSummary>, String>>

Retrieves all application manifests.

impl Provider for WadmProvider

async fn shutdown(&self) -> Result<()>

Handle shutdown request by closing all connections

async fn receive_link_config_as_target( &self, link_config: LinkConfig<'_>, ) -> Result<()>

Receive and handle a link that has been established on the lattice where this provider is the target.

async fn receive_link_config_as_source( &self, link_config: LinkConfig<'_>, ) -> Result<()>

Receive and handle a link that has been established on the lattice where this provider is the source.

async fn delete_link_as_source(&self, info: impl LinkDeleteInfo) -> Result<()>

Notify the provider that the link is dropped where the provider is the source

async fn delete_link_as_target(&self, info: impl LinkDeleteInfo) -> Result<()>

Notify the provider that the link is dropped where the provider is the target

fn init( &self, init_config: impl ProviderInitConfig, ) -> impl Future<Output = Result<(), E>> + Send

Initialize the provider

fn on_config_update( &self, update: impl ProviderConfigUpdate, ) -> impl Future<Output = Result<(), E>> + Send

Process a configuration update for the provider

fn health_request( &self, _arg: &HealthCheckRequest, ) -> impl Future<Output = Result<HealthCheckResponse, E>> + Send

Perform health check. Called at regular intervals by host Default implementation always returns healthy