Struct McpBindingCache 

pub struct McpBindingCache { /* private fields */ }

Shared across runs, but never across distinct owner/config/auth/env keys.

Ready lookups take a read lock. Refresh publication, invalidation and RAII cancellation take short write locks, never held across connector I/O.

Implementations

impl McpBindingCache

pub fn pin( &self, request: &McpBindingRequest, ) -> Result<McpBindingTicket, McpBindingError>

Pin the generation before inspecting a catalog or preparing a step.

Errors

Rejects new tickets after shutdown has closed admission.

pub fn observe( &self, request: &McpBindingRequest, ) -> Result<McpLifecycleSubscription, McpBindingError>

Observe only this exact verified owner/config/auth/environment binding. Creates a dormant/auth-required entry, never starts a server.

Errors

Rejects shutdown or generation invalidation racing observation admission.

pub fn catalog( &self, ticket: &McpBindingTicket, ) -> Result<Option<ServerToolCatalog>, McpBindingError>

Read complete discovery for exactly this owner and generation.

Errors

Rejects stale tickets and shutdown; never substitutes a newer catalog.

pub async fn get_or_connect<F, Fut>( &self, request: Arc<McpBindingRequest>, connect: F, ) -> Result<Arc<McpBinding>, McpBindingError>

where F: FnOnce(Arc<McpBindingRequest>) -> Fut, Fut: Future<Output = Result<ConnectedMcpServer, McpBindingError>>,

Reuse a ready binding or share one caller-owned connection attempt.

The connector receives the exact snapshot, must return an exclusively owned single-server registry, and must unwind partial resources on drop. It owns connect/list timeouts and credential resolution against the pinned identity. This function does not spawn, retry or substitute global inputs.

Errors

Returns authentication, connector, identity, invalidation or cancellation errors. Every waiter on the same attempt receives the same result.

pub async fn get_or_connect_pinned<F, Fut>( &self, ticket: &McpBindingTicket, request: Arc<McpBindingRequest>, connect: F, ) -> Result<Arc<McpBinding>, McpBindingError>

where F: FnOnce(Arc<McpBindingRequest>) -> Fut, Fut: Future<Output = Result<ConnectedMcpServer, McpBindingError>>,

Obtain readiness without allowing an already-prepared step to advance its binding generation implicitly.

Errors

Returns stale-ticket errors in addition to the ordinary binding errors.

pub fn invalidate(&self, key: &McpBindingKey)

Revoke one identity, including retained views, and advance its generation. An outstanding attempt must unwind before a replacement starts.

pub fn invalidate_owner(&self, owner: &ActorOwner)

Revoke every configuration/credential/environment revision of one owner.

pub fn invalidate_server(&self, server: &str)

Revoke every owner/config/auth/environment revision of one server.

pub fn retire_connection( &self, ticket: &McpBindingTicket, ) -> Result<(), McpBindingError>

Retire a disconnected transport but preserve its complete catalog for a later lazy start. Existing prepared steps are invalidated, not retargeted.

Errors

Rejects stale tickets and shutdown. The host must re-prepare before use.

pub async fn reap_retired(&self)

Join retired transports outside the cache lock; safe to cancel and resume. Newly retired bindings remain queued for the next call.

pub async fn shutdown(&self)

Permanently close admission, unwind refreshes, then join all transports. Retired handles stay in shared state if this future is cancelled.

Trait Implementations

impl Clone for McpBindingCache

fn clone(&self) -> McpBindingCache

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for McpBindingCache

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for McpBindingCache

fn default() -> McpBindingCache

Returns the “default value” for a type.