Struct UpstreamMcpProvider 

pub struct UpstreamMcpProvider { /* private fields */ }

Implementations

impl UpstreamMcpProvider

pub fn new(catalog: ProviderCatalog) -> Self

pub fn arc(catalog: ProviderCatalog) -> Arc<Self>

Trait Implementations

impl Clone for UpstreamMcpProvider

fn clone(&self) -> UpstreamMcpProvider

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Provider for UpstreamMcpProvider

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 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.

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>

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

Clears runtime quarantine after explicit operator authorization.

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].