Struct PluginManager 

pub struct PluginManager { /* private fields */ }

Plugin manager - registry for all extensions

The kernel uses this to discover and invoke extensions.

Implementations

impl PluginManager

pub fn new() -> Self

Create a new plugin manager

pub fn register_storage( &self, ext: Arc<dyn StorageExtension>, ) -> KernelResult<()>

Register a storage extension

pub fn set_active_storage(&self, name: &str) -> KernelResult<()>

Set the active storage backend

pub fn storage(&self) -> Option<Arc<dyn StorageExtension>>

Get the active storage backend

pub fn register_index( &self, ext: Arc<RwLock<dyn IndexExtension>>, ) -> KernelResult<()>

Register an index extension

pub fn index(&self, name: &str) -> Option<Arc<RwLock<dyn IndexExtension>>>

Get an index extension by name

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

List registered index types

pub fn register_observability( &self, ext: Arc<dyn ObservabilityExtension>, ) -> KernelResult<()>

Register an observability extension

Multiple observability extensions can be registered (fan-out to all)

pub fn counter_inc(&self, name: &str, value: u64, labels: &[(&str, &str)])

Record a counter across all observability extensions

pub fn gauge_set(&self, name: &str, value: f64, labels: &[(&str, &str)])

Record a gauge across all observability extensions

pub fn histogram_observe(&self, name: &str, value: f64, labels: &[(&str, &str)])

Record a histogram observation across all observability extensions

pub fn report_health(&self, health: &HealthInfo)

Report health to all observability extensions

pub fn has_observability(&self) -> bool

Check if any observability is configured

pub fn register_compression( &self, ext: Arc<dyn CompressionExtension>, ) -> KernelResult<()>

Register a compression extension

pub fn compression( &self, algorithm: &str, ) -> Option<Arc<dyn CompressionExtension>>

Get a compression extension by algorithm name

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

List available compression algorithms

pub fn shutdown_all(&self) -> KernelResult<()>

Shutdown all extensions gracefully

Calls shutdown() on each registered extension in reverse registration order. This allows extensions to release resources, close connections, flush buffers, etc.

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

Get information about all registered extensions

Trait Implementations

impl Default for PluginManager

fn default() -> Self

Returns the “default value” for a type.