Struct ProviderRegistry

Source

pub struct ProviderRegistry { /* private fields */ }

Expand description

Registry of named data providers

Allows registration of multiple providers and selection by name. Thread-safe for use in concurrent contexts.

§Example

let mut registry = ProviderRegistry::new();

// Register market data provider
let md_provider = Arc::new(DataFrameAdapter::new(...));
registry.register("data", md_provider);

// Register an additional provider
let alt_provider = Arc::new(AnotherProvider::new(...));
registry.register("alt", alt_provider);

// Set default
registry.set_default("data")?;

// Get provider by name
let provider = registry.get("data")?;

Implementations§

Source §

impl ProviderRegistry

Source

pub fn new() -> Self

Create a new empty provider registry

Source

pub fn register(&self, name: &str, provider: SharedAsyncProvider)

Register a provider with a name

§Arguments

name - Provider name (e.g., “data”, “api”, “warehouse”)
provider - AsyncDataProvider implementation

§Example

registry.register("data", Arc::new(DataFrameAdapter::new(...)));

Source

pub fn get(&self, name: &str) -> Option<SharedAsyncProvider>

Get provider by name

§Arguments

name - Provider name to lookup

§Returns

SharedAsyncProvider if found, None otherwise

Source

pub fn set_default(&self, name: &str) -> Result<()>

Set default provider

§Arguments

name - Name of provider to use as default

§Errors

Returns error if provider with given name is not registered

Source

pub fn get_default(&self) -> Option<SharedAsyncProvider>

Get default provider

§Returns

SharedAsyncProvider if a default is set, None otherwise

Source

pub fn default_name(&self) -> Option<String>

Get default provider name

Source

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

List all registered provider names

§Returns

Vector of provider names currently registered

Source

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

Check if a provider is registered

Source

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

Unregister a provider

§Arguments

name - Provider name to remove

§Returns

true if provider was removed, false if not found

Source

pub fn clear(&self)

Clear all providers

Source

pub fn load_extension( &self, path: &Path, config: &Value, ) -> Result<LoadedPlugin>

Load an extension module from a shared library

§Arguments

path - Path to the extension shared library (.so, .dll, .dylib)
config - Configuration value for the extension

§Returns

Information about the loaded extension

§Safety

Loading modules executes arbitrary code. Only load from trusted sources.

Source

pub fn load_extension_with_sections( &self, path: &Path, config: &Value, extension_sections: &HashMap<String, Value>, all_claimed: &mut HashSet<String>, ) -> Result<LoadedPlugin>

Load an extension, merging claimed TOML section data into its init config.

For each section claimed by the extension, looks it up in the project’s extension_sections and merges the data as JSON into the config. Errors if a required section is missing.

Source

pub fn get_language_runtime( &self, language_id: &str, ) -> Option<Arc<PluginLanguageRuntime>>

Get a language runtime by language identifier (e.g., “python”).

Source

pub fn language_runtimes(&self) -> HashMap<String, Arc<PluginLanguageRuntime>>

Return all loaded language runtimes, keyed by language identifier.

Source

pub fn language_runtime_lsp_configs(&self) -> Vec<RuntimeLspConfig>

Return child-LSP configurations declared by loaded language runtimes.

Source

pub fn get_extension(&self, name: &str) -> Option<Arc<PluginDataSource>>

Get an extension data source by name

§Arguments

name - Extension name

§Returns

The PluginDataSource if found

Source

pub fn get_extension_module_schema( &self, module_name: &str, ) -> Option<ParsedModuleSchema>

Get extension module schema by module namespace name.

Source

pub fn module_exports_from_extensions(&self) -> Vec<ModuleExports>

Build runtime extension modules from all loaded extension module capabilities.

Strict-typing follow-up plugin-typed-abi: the ValueWord-typed dispatch shim was removed with the bulldozer; plugins are inert until they declare typed signatures at registration. See the 2026-05-06 entry in docs/defections.md.

Source