Struct PluginRegistry 

pub struct PluginRegistry {
    pub db: Db,
    pub runtime: Runtime,
    /* private fields */
}

Fields

db: Db

runtime: Runtime

Implementations

impl PluginRegistry

pub fn new(db: Db, runtime: Runtime) -> Result<Self>

pub fn plugins(&self) -> &HashMap<String, WitmPlugin>

pub async fn load_plugins(&mut self) -> Result<()>

pub async fn plugin_from_component( &self, component_bytes: Vec<u8>, ) -> Result<WitmPlugin>

pub async fn plugin_from_component_with_key( &self, component_bytes: Vec<u8>, expected_public_key: Option<&[u8]>, ) -> Result<WitmPlugin>

Load and verify a plugin from WASM bytes.

If expected_public_key is provided, the plugin’s embedded public key must match it exactly — this lets callers pin trust to a known author rather than accepting any self-signed component.

pub async fn register_plugin(&mut self, plugin: WitmPlugin) -> Result<()>

pub async fn remove_plugin( &mut self, name: &str, namespace: Option<&str>, ) -> Result<Vec<String>>

pub fn find_first_unexecuted_plugin( &self, event: &dyn Event, executed_plugins: &HashSet<String>, ) -> Option<&WitmPlugin>

pub fn can_handle(&self, event: &dyn Event) -> bool

Check if any plugins can handle an event

pub fn effective_plugins_for_tenant( &self, overrides: &[TenantPluginOverride], ) -> HashSet<String>

Returns the set of plugin IDs that are effective for a given tenant. Applies per-tenant enable/disable overrides on top of global enabled state.

pub fn resolve_config( &self, plugin: &WitmPlugin, tenant_config: &[TenantPluginConfig], ) -> Vec<UserInput>

Resolve configuration for a plugin, merging tenant-specific config over global defaults. Tenant config values are stored as JSON strings in the database.

pub async fn handle_event( &self, event: Box<dyn Event>, ) -> Result<(WasmEvent, Store<Host>)>

Handle a generic event, passing it through all registered plugins, and returning the final Event (whose inner contents implement Event) and Store (for resolving any resource handles on the host side) Validates that the final Event matches the expected output type for its event kind, returning an error if not

pub async fn handle_event_for_tenant( &self, event: Box<dyn Event>, effective_set: &HashSet<String>, tenant_config: &[TenantPluginConfig], ) -> Result<(WasmEvent, Store<Host>)>

Handle an event with tenant-specific plugin filtering and configuration. Uses effective_set to filter plugins and tenant_config to override per-plugin config.