Trait CoreProvider
pub trait CoreProvider: Send + Sync {
// Required methods
fn catalog(&self) -> ProviderManifest;
fn call<'life0, 'async_trait>(
&'life0 self,
call: ProviderCall,
) -> Pin<Box<dyn Future<Output = Result<ProviderOutput, ProviderError>> + Send + 'async_trait>>
where 'life0: 'async_trait,
Self: 'async_trait;
// Provided methods
fn retire<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
where 'life0: 'async_trait,
Self: 'async_trait { ... }
fn suspend<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
where 'life0: 'async_trait,
Self: 'async_trait { ... }
fn runtime_status(&self) -> Option<Value> { ... }
fn cancel_active(&self) -> bool { ... }
fn reset_quarantine<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
where 'life0: 'async_trait,
Self: 'async_trait { ... }
fn deactivate(&self) { ... }
fn activate(&self) { ... }
fn acquire_dispatch(&self) -> bool { ... }
fn release_dispatch(&self) { ... }
}Required Methods§
fn catalog(&self) -> ProviderManifest
fn call<'life0, 'async_trait>(
&'life0 self,
call: ProviderCall,
) -> Pin<Box<dyn Future<Output = Result<ProviderOutput, ProviderError>> + Send + 'async_trait>>where
'life0: 'async_trait,
Self: 'async_trait,
Provided Methods§
fn retire<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
'life0: 'async_trait,
Self: 'async_trait,
fn retire<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
'life0: 'async_trait,
Self: 'async_trait,
Stop accepting new work and release provider-owned runtime resources.
Stateless providers use the default no-op. Registries call this after an atomic generation swap, outside registry locks.
fn suspend<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
'life0: 'async_trait,
Self: 'async_trait,
fn suspend<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
'life0: 'async_trait,
Self: 'async_trait,
Parks runtime resources while keeping a retained generation callable.
fn runtime_status(&self) -> Option<Value>
fn runtime_status(&self) -> Option<Value>
Returns product-neutral operator status for a stateful runtime.
fn cancel_active(&self) -> bool
fn cancel_active(&self) -> bool
Cancels active runtime work without waiting for the provider call lock.
fn reset_quarantine<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
'life0: 'async_trait,
Self: 'async_trait,
fn reset_quarantine<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
'life0: 'async_trait,
Self: 'async_trait,
Clears runtime quarantine after explicit operator authorization.
fn deactivate(&self)
fn deactivate(&self)
Stops new work on a retained generation while in-flight work drains.
fn activate(&self)
fn activate(&self)
Re-enables a retained generation selected by operator rollback.
fn acquire_dispatch(&self) -> bool
fn acquire_dispatch(&self) -> bool
Acquires a dispatch lease while the provider is still active.
Registries call this while holding their generation read lock so an already-routed invocation can drain safely across an atomic swap.
fn release_dispatch(&self)
fn release_dispatch(&self)
Releases a dispatch lease acquired by Provider::acquire_dispatch.