Struct ExtensionBus 

pub struct ExtensionBus { /* private fields */ }

Global registry of discovered and provisioned capability extensions.

Implementations

impl ExtensionBus

pub fn new(extensions_dir: impl AsRef<Path>) -> Self

pub fn scan_and_load_extensions(&self)

Scans the extensions directory for manifest.json files and loads them into memory.

pub fn register_extension_from_path( &self, manifest_path: &Path, ) -> Result<(), String>

Register a new extension from an absolute path (CLI workflow)

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

Retrieve all registered manifests (used by the Studio UI)

pub fn query_capability(&self, interface_hash: u64) -> Vec<ExtensionManifest>

Query the bus for any extensions supporting a given semantic interface hash

pub fn dispatch_task( &self, extension_id: &str, input_file_path: &str, pipeline_steps: Vec<Value>, sensitivity_context: u64, guardianship_override: bool, ) -> Result<String, String>

Dispatches a task recipe to an extension over localhost RPC. Includes Sentinel Gatekeeping logic to enforce sensitivity classification.

pub async fn provision_asset( &self, extension_id: &str, asset_url: &str, filename: &str, ) -> Result<String, String>

B4: Provisioning Loop Downloads a required asset (e.g., ONNX model weights) for an extension into the extension’s local data directory.