Struct PluginManager 

pub struct PluginManager { /* private fields */ }

Plugin manager that caches loaded plugins.

Implementations

impl PluginManager

pub fn new() -> Self

Create a new plugin manager.

pub const fn with_config(config: RuntimeConfig) -> Self

Create a plugin manager with custom configuration.

pub fn load(&mut self, path: &Path) -> Result<usize>

Load a plugin from a file path.

pub fn load_bytes( &mut self, name: impl Into<String>, bytes: &[u8], ) -> Result<usize>

Load a plugin from bytes.

pub fn register_wasm_dir( &mut self, dir: impl AsRef<Path>, ) -> Result<WasmPluginDirScanReport>

Scan dir for *.wasm files (one level only — no recursion) and register each as a plugin.

Files are loaded in sorted order so multi-plugin pipelines have deterministic ordering across filesystems and platforms. Extension matching is case-insensitive — foo.wasm and BAR.WASM are both picked up.

Loading is skip-and-collect: every loadable module is registered; failures are accumulated in WasmPluginDirScanReport::failures so the caller can decide whether to log them, abort, or ignore. A single broken module in a dir with 19 good ones doesn’t prevent the 19 from loading. Mirrors ImporterRegistry::register_wasm_dir in rustledger-importer.

Non-.wasm files (a README.md or .gitignore) and subdirectories are silently skipped. Entries whose metadata can’t be read at all (broken symlinks; the file existed in read_dir’s listing but path.is_file() returns false) are also silently skipped — std::fs::DirEntry::path().is_file() swallows the underlying I/O error. If that matters for your use case, walk the dir yourself with explicit symlink_metadata checks.

Errors

The outer Result reports an I/O error reading dir itself (dir doesn’t exist, permission denied on the dir). Per-file load failures land inside the report’s failures vec so the caller can surface them without aborting the rest of the scan.

pub fn execute(&self, index: usize, input: &PluginInput) -> Result<PluginOutput>

Execute a plugin by index.

pub fn execute_all(&self, input: PluginInput) -> Result<PluginOutput>

Execute all loaded plugins in sequence.

Note: because the ops protocol references the plugin’s input indices and execute_all chains plugins by materializing each stage’s ops before feeding the next, the final ops returned here describe the result relative to the original input as a rebuild: every output directive is encoded as PluginOp::Insert and every original input is encoded as PluginOp::Delete. Loader callers don’t go through this path — they apply ops one plugin at a time — so this simplifies the multi-plugin WASM-runtime case to “here’s the resulting directive list” without losing the protocol’s invariants.

pub const fn len(&self) -> usize

Get the number of loaded plugins.

pub const fn is_empty(&self) -> bool

Check if any plugins are loaded.

Trait Implementations

impl Default for PluginManager

fn default() -> Self

Returns the “default value” for a type.