Struct APCore 

pub struct APCore {
    pub config: Config,
    /* private fields */
}

Main entry point for interacting with the APCore system.

Fields

config: Config

Implementations

impl APCore

pub fn new() -> APCore

Create a new APCore client with default configuration.

pub fn with_options( registry: Option<Registry>, executor: Option<Executor>, config: Option<Config>, metrics_collector: Option<MetricsCollector>, ) -> APCore

Create a new APCore client with all optional parameters.

If both executor and registry are provided, the executor takes precedence and the registry is ignored (the executor already contains its own registry).

pub fn with_config(config: Config) -> APCore

Create a new APCore client with the given configuration.

pub async fn call( &self, module_id: &str, inputs: Value, ctx: Option<&Context<Value>>, version_hint: Option<&str>, ) -> Result<Value, ModuleError>

Call (execute) a module by ID with the given inputs.

pub async fn call_async( &self, module_id: &str, inputs: Value, ctx: Option<&Context<Value>>, version_hint: Option<&str>, ) -> Result<Value, ModuleError>

Alias for call() — provided for spec compatibility.

pub async fn validate( &self, module_id: &str, inputs: &Value, ) -> Result<(), ModuleError>

Validate module inputs without executing.

pub fn register( &mut self, module_id: &str, module: Box<dyn Module>, ) -> Result<(), ModuleError>

Register a module with the given module_id.

pub async fn discover(&mut self) -> Result<usize, ModuleError>

Trigger module discovery.

pub fn list_modules( &self, tags: Option<&[String]>, prefix: Option<&str>, ) -> Vec<String>

List all registered modules, optionally filtered by tags and/or prefix.

pub fn use_middleware(&mut self, middleware: Box<dyn Middleware>)

Add a middleware to the execution pipeline.

pub fn remove(&mut self, name: &str) -> bool

Remove a middleware by name.

pub fn remove_middleware(&mut self, name: &str) -> bool

Remove a middleware by name (legacy alias).

pub fn registry(&self) -> &Registry

Get a reference to the registry.

pub fn executor(&self) -> &Executor

Get a reference to the executor.

pub fn disable( &mut self, _module_id: &str, _reason: Option<&str>, ) -> Result<(), ModuleError>

Disable a module with an optional reason.

pub fn enable( &mut self, _module_id: &str, _reason: Option<&str>, ) -> Result<(), ModuleError>

Re-enable a previously disabled module.

pub fn on( &mut self, _event_type: &str, subscriber: Box<dyn EventSubscriber>, ) -> String

Subscribe to an event type. Returns the subscriber ID.

Lazily initializes the event emitter on first use.

pub fn off(&mut self, subscriber_id: &str) -> bool

Unsubscribe by subscriber ID.

pub fn events(&self) -> Option<&EventEmitter>

Get the event emitter, if configured.

pub async fn reload(&mut self) -> Result<(), ModuleError>

Reload modules from the configured modules path.

pub async fn shutdown(&mut self) -> Result<(), ModuleError>

Shut down the client and release resources.

pub async fn stream( &self, module_id: &str, inputs: Value, ctx: Option<&Context<Value>>, version_hint: Option<&str>, ) -> Result<Vec<Value>, ModuleError>

Stream execution of a module.

pub fn describe(&self, module_id: &str) -> String

Describe a module by ID.

pub fn use_before(&mut self, middleware: Box<dyn BeforeMiddleware>)

Add a before callback middleware.

pub fn use_after(&mut self, middleware: Box<dyn AfterMiddleware>)

Add an after callback middleware.

Trait Implementations

impl Debug for APCore

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Default for APCore

fn default() -> APCore

Returns the “default value” for a type.