Struct SolutionRegistry 

pub struct SolutionRegistry<C: Connection> { /* private fields */ }

Registry for dynamically created solution handles.

Implementations

impl<C: Connection> SolutionRegistry<C>

pub fn new(config: SolutionRegistryConfig<C>) -> Self

pub async fn get_or_init( &self, solution: &str, ) -> Result<Arc<SolutionHandle<C>>, RegistryError>

Gets the solution handle or builds it once if missing.

If the handle has been idle longer than health_check_after, a ping is issued. On failure the stale handle is evicted and rebuilt.

Errors

Returns RegistryError if capacity is exceeded or the build fails.

pub async fn list_solutions(&self) -> Vec<String>

Lists known solutions by merging the in-memory cache with a live DB discovery query (INFO FOR NS).

When a discover_solutions function is configured it is called first; otherwise any live cached handle is used for the namespace query. If neither is available the result falls back to the cache alone.

pub async fn remove_solution(&self, solution: &str) -> bool

Removes a cached solution handle entry.

pub async fn evict_idle(&self) -> usize

Evicts idle entries that exceed the configured TTL.

pub fn spawn_sweeper(self) -> Option<JoinHandle<()>>

where C: Send + Sync + 'static,

Spawns a background task to evict idle entries on a schedule.

Trait Implementations

impl<C: Clone + Connection> Clone for SolutionRegistry<C>

fn clone(&self) -> SolutionRegistry<C>

Returns a duplicate of the value.

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

Performs copy-assignment from source.