Struct PluginRegistry 

pub struct PluginRegistry { /* private fields */ }

Thread-safe registry for custom forecast models and anomaly detectors.

Plugins register factory functions keyed by name. The factories are called at runtime to create model/detector instances with user-supplied config.

All registration and lookup operations are lock-free (DashMap-backed) and safe under concurrent access. Registration uses atomic entry-based insertion to prevent TOCTOU races.

Implementations

impl PluginRegistry

pub fn new() -> Self

Create an empty registry.

pub fn register_model( &self, name: impl Into<String>, factory: ModelFactory, ) -> Result<(), PluginError>

Register a custom forecast model factory.

Returns an error if the name is invalid or a model with the same name is already registered. Uses atomic entry insertion to prevent TOCTOU races.

pub fn register_model_with_info( &self, info: PluginInfo, factory: ModelFactory, ) -> Result<(), PluginError>

Register a custom forecast model factory with explicit metadata.

pub fn replace_model( &self, name: impl Into<String>, factory: ModelFactory, ) -> Result<Option<PluginInfo>, PluginError>

Atomically replace a model factory. Inserts if not present.

Returns the previous PluginInfo if there was an existing registration.

pub fn replace_model_with_info( &self, info: PluginInfo, factory: ModelFactory, ) -> Result<Option<PluginInfo>, PluginError>

Atomically replace a model factory with explicit metadata.

pub fn create_model( &self, name: &str, config: &Value, ) -> Result<Box<dyn ForecastModel>, PluginError>

Create a forecast model instance by plugin name.

pub fn create_model_default( &self, name: &str, ) -> Result<Box<dyn ForecastModel>, PluginError>

Create a forecast model with default (null) configuration.

pub fn try_create_model( &self, name: &str, config: &Value, ) -> Option<Result<Box<dyn ForecastModel>, PluginError>>

Try to create a forecast model if the plugin is registered.

Returns None if no plugin with the given name exists. Returns Some(Err(...)) if the plugin exists but the factory fails. Single DashMap lookup — no TOCTOU.

pub fn try_create_model_default( &self, name: &str, ) -> Option<Result<Box<dyn ForecastModel>, PluginError>>

Try to create a forecast model with default config (single lookup).

pub fn has_model(&self, name: &str) -> bool

Check if a model plugin is registered.

pub fn model_info(&self, name: &str) -> Option<PluginInfo>

Get metadata for a registered model plugin.

pub fn list_models(&self) -> Vec<String>

List all registered model plugin names (sorted).

pub fn list_model_infos(&self) -> Vec<PluginInfo>

List all registered model plugins with their metadata (sorted by name).

pub fn unregister_model(&self, name: &str) -> Option<PluginInfo>

Unregister a model plugin. Returns the PluginInfo if it existed.

pub fn model_count(&self) -> usize

Number of registered model plugins.

pub fn register_detector( &self, name: impl Into<String>, factory: DetectorFactory, ) -> Result<(), PluginError>

Register a custom anomaly detector factory.

Returns an error if the name is invalid or a detector with the same name is already registered. Uses atomic entry insertion to prevent TOCTOU races.

pub fn register_detector_with_info( &self, info: PluginInfo, factory: DetectorFactory, ) -> Result<(), PluginError>

Register a custom anomaly detector factory with explicit metadata.

pub fn replace_detector( &self, name: impl Into<String>, factory: DetectorFactory, ) -> Result<Option<PluginInfo>, PluginError>

Atomically replace a detector factory. Inserts if not present.

Returns the previous PluginInfo if there was an existing registration.

pub fn replace_detector_with_info( &self, info: PluginInfo, factory: DetectorFactory, ) -> Result<Option<PluginInfo>, PluginError>

Atomically replace a detector factory with explicit metadata.

pub fn create_detector( &self, name: &str, config: &Value, ) -> Result<Box<dyn AnomalyDetector>, PluginError>

Create an anomaly detector instance by plugin name.

pub fn create_detector_default( &self, name: &str, ) -> Result<Box<dyn AnomalyDetector>, PluginError>

Create an anomaly detector with default (null) configuration.

pub fn try_create_detector( &self, name: &str, config: &Value, ) -> Option<Result<Box<dyn AnomalyDetector>, PluginError>>

Try to create an anomaly detector if the plugin is registered.

Returns None if no plugin with the given name exists. Returns Some(Err(...)) if the plugin exists but the factory fails. Single DashMap lookup — no TOCTOU.

pub fn try_create_detector_default( &self, name: &str, ) -> Option<Result<Box<dyn AnomalyDetector>, PluginError>>

Try to create an anomaly detector with default config (single lookup).

pub fn has_detector(&self, name: &str) -> bool

Check if a detector plugin is registered.

pub fn detector_info(&self, name: &str) -> Option<PluginInfo>

Get metadata for a registered detector plugin.

pub fn list_detectors(&self) -> Vec<String>

List all registered detector plugin names (sorted).

pub fn list_detector_infos(&self) -> Vec<PluginInfo>

List all registered detector plugins with their metadata (sorted by name).

pub fn unregister_detector(&self, name: &str) -> Option<PluginInfo>

Unregister a detector plugin. Returns the PluginInfo if it existed.

pub fn detector_count(&self) -> usize

Number of registered detector plugins.

pub fn total_plugins(&self) -> usize

Total number of registered plugins (models + detectors).

pub fn clear(&self)

Remove all registered models and detectors.

pub fn set_model_allowlist(&self, hashes: impl IntoIterator<Item = String>)

Set the SHA-256 hash allowlist for model plugins.

When the allowlist is non-empty, only plugins whose PluginInfo::sha256_hash is present in the list are accepted. Hashes should be lowercase hex-encoded.

pub fn set_detector_allowlist(&self, hashes: impl IntoIterator<Item = String>)

Set the SHA-256 hash allowlist for detector plugins.

Trait Implementations

impl Debug for PluginRegistry

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

Formats the value using the given formatter.

impl Default for PluginRegistry

fn default() -> Self

Returns the “default value” for a type.