Trait PluginRpcHandler 

pub trait PluginRpcHandler<R: Reactor = TokioReactor>:
    Send
    + Sync
    + 'static {
    // Required methods
    fn list_plugins(&self) -> Vec<Value>;
    fn load_plugin(&self, path: &str) -> Result<Value, String>;
    fn unload_plugin(&self, name: &str) -> Result<(), String>;
    fn reload_plugin(&self, name: &str) -> Result<Value, String>;
    fn spawn_actor(
        &self,
        type_name: &str,
        config: &[u8],
    ) -> Result<Box<dyn Actor<R>>, String>;
}

Extension point for plugin management RPCs.

Implement this trait in the application layer (e.g., wrapping a PluginRegistry from pd-plugin) and inject it into EngineConfig to enable plugin.* control-plane methods. When None, those methods return a “not implemented” error.

Required Methods

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

List all currently loaded plugins.

fn load_plugin(&self, path: &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.

Implementors