Struct ClientHub 

pub struct ClientHub { /* private fields */ }

Type-safe registry of clients keyed by interface type.

Implementations

impl ClientHub

pub fn new() -> Self

impl ClientHub

pub fn register<T>(&self, client: Arc<T>)

where T: ?Sized + Send + Sync + 'static,

Register a client under the interface type T. T can be a trait object like dyn my_gear::api::MyClient.

pub fn register_scoped<T>(&self, scope: ClientScope, client: Arc<T>)

where T: ?Sized + Send + Sync + 'static,

Register a scoped client under the interface type T.

This enables multiple implementations of the same interface to coexist, distinguished by a caller-defined ClientScope (e.g., a GTS instance ID).

pub fn get<T>(&self) -> Result<Arc<T>, ClientHubError>

where T: ?Sized + Send + Sync + 'static,

Fetch a client by interface type T.

Errors

Returns ClientHubError::NotFound if no client is registered for the type. Returns ClientHubError::TypeMismatch if the stored type doesn’t match.

pub fn try_get<T>(&self) -> Option<Arc<T>>

where T: ?Sized + Send + Sync + 'static,

Try to fetch a client by interface type T.

Returns None if no client is registered for the type or if the stored type doesn’t match. This sees every registration, proxies included — use Self::try_get_local when the answer needs to mean “satisfied in-process”.

pub fn register_remote_proxy<T>(&self, client: Arc<T>)

where T: ?Sized + Send + Sync + 'static,

Register a client that is a discovery-resolving proxy to a remote provider, not an in-process implementation.

Stored exactly like Self::register; the difference is that the type is remembered as remote so Self::try_get_local will not report it as a local implementation.

pub fn try_get_local<T>(&self) -> Option<Arc<T>>

where T: ?Sized + Send + Sync + 'static,

Try to fetch a client by interface type T, ignoring remote proxies.

This is the short-circuit probe for consumer wiring: a compile-time (local) registration takes priority over a discovery-based proxy, so the wiring closure asks whether a local implementation exists before registering one of its own.

Using plain Self::try_get here would be wrong when two consumers in one process depend on the same contract: whichever wires second would find the first one’s proxy, conclude the dependency is local, and mark it readiness-resolved — turning /readyz green before the provider exists.

pub fn has_remote_proxy<T>(&self) -> bool

where T: ?Sized + Send + Sync + 'static,

Whether a remote proxy is already registered for interface type T.

Lets consumer wiring reuse an existing proxy instead of building and registering a second identical one for the same contract.

pub fn get_scoped<T>( &self, scope: &ClientScope, ) -> Result<Arc<T>, ClientHubError>

where T: ?Sized + Send + Sync + 'static,

Fetch a scoped client by interface type T and scope.

Errors

Returns ClientHubError::ScopedNotFound if no client is registered for the (type, scope) pair. Returns ClientHubError::ScopedTypeMismatch if the stored type doesn’t match.

pub fn try_get_scoped<T>(&self, scope: &ClientScope) -> Option<Arc<T>>

where T: ?Sized + Send + Sync + 'static,

Try to fetch a scoped client by interface type T and scope.

Returns None if not found or if the stored type doesn’t match.

pub fn remove<T>(&self) -> Option<Arc<T>>

where T: ?Sized + Send + Sync + 'static,

Remove a client by interface type; returns the removed client if it was present.

pub fn remove_scoped<T>(&self, scope: &ClientScope) -> Option<Arc<T>>

where T: ?Sized + Send + Sync + 'static,

Remove a scoped client by interface type + scope; returns the removed client if it was present.

pub fn clear(&self)

Clear everything (useful in tests).

pub fn len(&self) -> usize

Introspection: (total entries).

pub fn is_empty(&self) -> bool

Check if the hub is empty.

Trait Implementations

impl Default for ClientHub

fn default() -> Self

Returns the “default value” for a type.