Struct RegistryRpcHandler 

pub struct RegistryRpcHandler<R: Reactor> { /* private fields */ }

A PluginRpcHandler backed by a locked PluginRegistry.

Each RPC call acquires the mutex for the duration of the operation. For plugin.reload, the handler re-loads from the same path that was recorded at plugin.load time; see RegistryRpcHandler::with_wasm_host.

Implementations

impl<R: Reactor> RegistryRpcHandler<R>

pub fn new() -> Self

Create a handler backed by an empty registry.

pub fn with_registry(registry: Arc<Mutex<PluginRegistry<R>>>) -> Self

Attach an existing registry (e.g., pre-loaded with static plugins).

pub fn with_wasm_host(self, host: Arc<dyn WasmHost>) -> Self

Enable WASM plugin loading with the given WasmHost.

pub fn registry(&self) -> Arc<Mutex<PluginRegistry<R>>>

Expose the underlying registry for spawning actors.

Trait Implementations

impl<R: Reactor> Default for RegistryRpcHandler<R>

fn default() -> Self

Returns the “default value” for a type.

impl<R: Reactor> PluginRpcHandler<R> for RegistryRpcHandler<R>

fn list_plugins(&self) -> Vec<Value>

List all currently loaded plugins.

fn load_plugin(&self, path_str: &str) -> Result<Value, String>

Load a plugin from the given file path. Returns plugin info on success.

fn unload_plugin(&self, name: &str) -> Result<(), String>

Unload a plugin by name.

fn reload_plugin(&self, name: &str) -> Result<Value, String>

Reload a plugin by name (unload + load from the same path).

fn spawn_actor( &self, type_name: &str, config: &[u8], ) -> Result<Box<dyn Actor<R>>, String>

Spawn an actor instance for a registered type.