Struct PythonProvider 

pub struct PythonProvider { /* private fields */ }

Implementations

impl PythonProvider

pub async fn preflight(&self) -> Result<(), ProviderError>

Starts, negotiates, describes, and health-checks a persistent worker. One-shot providers have no persistent preflight and return immediately.

pub fn new( path: PathBuf, catalog: ProviderCatalog, env_prefix: impl Into<String>, ) -> Self

pub fn new_with_interpreter( path: PathBuf, catalog: ProviderCatalog, env_prefix: impl Into<String>, interpreter: PythonInterpreter, ) -> Self

pub fn new_persistent( path: PathBuf, catalog: ProviderCatalog, env_prefix: impl Into<String>, interpreter: PythonInterpreter, config: PythonSupervisorConfig, ) -> Result<Self, ProviderError>

Builds a provider backed by one lazily-started persistent worker.

pub fn arc_persistent( path: PathBuf, catalog: ProviderCatalog, env_prefix: impl Into<String>, interpreter: PythonInterpreter, config: PythonSupervisorConfig, ) -> Result<Arc<Self>, ProviderError>

pub fn arc_persistent_in_generation( path: PathBuf, catalog: ProviderCatalog, env_prefix: impl Into<String>, interpreter: PythonInterpreter, config: PythonSupervisorConfig, immutable_generation_digest: String, ) -> Result<Arc<Self>, ProviderError>

Builds a persistent provider whose identity and worker budget are bound to the complete immutable source-tree generation.

pub fn arc( path: PathBuf, catalog: ProviderCatalog, env_prefix: impl Into<String>, ) -> Arc<Self>

pub fn arc_with_interpreter( path: PathBuf, catalog: ProviderCatalog, env_prefix: impl Into<String>, interpreter: PythonInterpreter, ) -> Arc<Self>

Trait Implementations

impl Clone for PythonProvider

fn clone(&self) -> PythonProvider

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Provider for PythonProvider

fn catalog(&self) -> ProviderCatalog

fn call<'life0, 'async_trait>( &'life0 self, call: ProviderCall, ) -> Pin<Box<dyn Future<Output = Result<ProviderOutput, ProviderError>> + Send + 'async_trait>>

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

fn runtime_status(&self) -> Option<Value>

Returns product-neutral operator status for a stateful runtime.

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 Self: 'async_trait, 'life0: 'async_trait,

Clears runtime quarantine after explicit operator authorization.

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

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

Parks runtime resources while keeping a retained generation callable.

fn deactivate(&self)

Stops new work on a retained generation while in-flight work drains.

fn activate(&self)

Re-enables a retained generation selected by operator rollback.

fn acquire_dispatch(&self) -> bool

Acquires a dispatch lease while the provider is still active.

fn release_dispatch(&self)

Releases a dispatch lease acquired by [Provider::acquire_dispatch].

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

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

Stop accepting new work and release provider-owned runtime resources.