Struct ProviderRegistry 

pub struct ProviderRegistry { /* private fields */ }

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

impl ProviderRegistry

pub fn new() -> Self

Create a new empty provider registry

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(...)));

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

Get provider by name

Arguments

• name - Provider name to lookup

Returns

SharedAsyncProvider if found, None otherwise

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

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

Get default provider

Returns

SharedAsyncProvider if a default is set, None otherwise

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

Get default provider name

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

List all registered provider names

Returns

Vector of provider names currently registered

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

Check if a provider is registered

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

pub fn clear(&self)

Clear all providers

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.

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.

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

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

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

Return all loaded language runtimes, keyed by language identifier.

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

Return child-LSP configurations declared by loaded language runtimes.

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

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

Get extension module schema by module namespace name.

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

Build runtime extension modules from all loaded extension module capabilities.

pub fn invoke_extension_module_nb( &self, module_name: &str, function: &str, args: &[ValueWord], ) -> Result<ValueWord>

Invoke a module-capability export by module namespace and function name.

pub fn invoke_extension_module_wire( &self, module_name: &str, function: &str, args: &[WireValue], ) -> Result<WireValue>

Invoke a module-capability export by module namespace and function name.

pub fn get_extension_query_schema( &self, name: &str, ) -> Option<ParsedQuerySchema>

Get query schema for an extension (for LSP autocomplete)

Arguments

• name - Extension name

Returns

The query schema if extension exists

pub fn get_extension_output_schema( &self, name: &str, ) -> Option<ParsedOutputSchema>

Get output schema for an extension (for LSP autocomplete)

Arguments

• name - Extension name

Returns

The output schema if extension exists

pub fn list_extensions_with_schemas(&self) -> Vec<(String, ParsedQuerySchema)>

List all plugins with their query schemas (for LSP)

Returns

Vector of (plugin_name, query_schema) pairs

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

List all loaded extension names

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

Check if a plugin is loaded

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

Unload an extension

Arguments

• name - Extension name to unload

Returns

true if plugin was unloaded, false if not found

Trait Implementations

impl Clone for ProviderRegistry

fn clone(&self) -> ProviderRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for ProviderRegistry

fn default() -> Self

Returns the “default value” for a type.