pub struct WadmProvider { /* private fields */ }
Implementations§
Source§impl WadmProvider
impl WadmProvider
pub async fn run() -> Result<()>
Sourcepub fn from_host_data(host_data: &HostData) -> WadmProvider
pub fn from_host_data(host_data: &HostData) -> WadmProvider
Build a WadmProvider
from HostData
Trait Implementations§
Source§impl Clone for WadmProvider
impl Clone for WadmProvider
Source§fn clone(&self) -> WadmProvider
fn clone(&self) -> WadmProvider
Returns a copy of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moreSource§impl Default for WadmProvider
impl Default for WadmProvider
Source§impl Handler<Option<Context>> for WadmProvider
impl Handler<Option<Context>> for WadmProvider
Source§async fn deploy_model(
&self,
ctx: Option<Context>,
model_name: String,
version: Option<String>,
lattice: Option<String>,
) -> Result<Result<String, String>>
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.
Source§async fn undeploy_model(
&self,
ctx: Option<Context>,
model_name: String,
lattice: Option<String>,
non_destructive: bool,
) -> Result<Result<(), String>>
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.
Source§async fn put_model(
&self,
ctx: Option<Context>,
model: String,
lattice: Option<String>,
) -> Result<Result<(String, String), String>>
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.
Source§async fn put_manifest(
&self,
ctx: Option<Context>,
manifest: OamManifest,
lattice: Option<String>,
) -> Result<Result<(String, String), String>>
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.
Source§async fn get_model_history(
&self,
ctx: Option<Context>,
model_name: String,
lattice: Option<String>,
) -> Result<Result<Vec<VersionInfo>, String>>
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.
Source§async fn get_model_status(
&self,
ctx: Option<Context>,
model_name: String,
lattice: Option<String>,
) -> Result<Result<Status, String>>
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.
Source§async fn get_model_details(
&self,
ctx: Option<Context>,
model_name: String,
version: Option<String>,
lattice: Option<String>,
) -> Result<Result<OamManifest, String>>
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.
Source§impl Provider for WadmProvider
impl Provider for WadmProvider
Source§async fn receive_link_config_as_target(
&self,
link_config: LinkConfig<'_>,
) -> Result<()>
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. Read more
Source§async fn receive_link_config_as_source(
&self,
link_config: LinkConfig<'_>,
) -> Result<()>
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. Read more
Source§async fn delete_link_as_source(&self, info: impl LinkDeleteInfo) -> Result<()>
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
Source§async fn delete_link_as_target(&self, info: impl LinkDeleteInfo) -> Result<()>
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
Source§fn init(
&self,
init_config: impl ProviderInitConfig,
) -> impl Future<Output = Result<(), E>> + Send
fn init( &self, init_config: impl ProviderInitConfig, ) -> impl Future<Output = Result<(), E>> + Send
Initialize the provider Read more
Source§fn on_config_update(
&self,
update: impl ProviderConfigUpdate,
) -> impl Future<Output = Result<(), E>> + Send
fn on_config_update( &self, update: impl ProviderConfigUpdate, ) -> impl Future<Output = Result<(), E>> + Send
Process a configuration update for the provider Read more
Source§fn health_request(
&self,
_arg: &HealthCheckRequest,
) -> impl Future<Output = Result<HealthCheckResponse, E>> + Send
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
Auto Trait Implementations§
impl Freeze for WadmProvider
impl !RefUnwindSafe for WadmProvider
impl Send for WadmProvider
impl Sync for WadmProvider
impl Unpin for WadmProvider
impl !UnwindSafe for WadmProvider
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request