Struct HostRuntime 

pub struct HostRuntime<P> {
    plugin: P,
    meta: PluginMeta,
    plugin_id: String,
    _node: Node<IpcService>,
    task_server: TaskServer,
    daemon_event_sub: DaemonEventSubscriber,
    plugin_event_pub: PluginEventPublisher,
    result_pub: ResultPublisher,
    result_subscriptions: Vec<(String, ResultSubscriber)>,
    wakeup_listener: PluginWakeupListener,
    shutdown: AtomicBool,
}

Host plugin runtime with WaitSet-driven event loop.

Fields

plugin: P

meta: PluginMeta

plugin_id: String

_node: Node<IpcService>

task_server: TaskServer

daemon_event_sub: DaemonEventSubscriber

plugin_event_pub: PluginEventPublisher

result_pub: ResultPublisher

result_subscriptions: Vec<(String, ResultSubscriber)>

wakeup_listener: PluginWakeupListener

shutdown: AtomicBool

Implementations

impl<P: HostPlugin> HostRuntime<P>

pub fn new( plugin: P, meta: PluginMeta, subscribed_plugins: &[&str], ) -> Result<Self>

Create a new host plugin runtime.

subscribed_plugins is the list of plugin IDs this plugin subscribes to for event/result chaining (declared via macro).

pub fn run(&self) -> Result<()>

Run the plugin event loop. Blocks until shutdown.

fn drain_tasks(&self)

fn drain_daemon_events(&self)

fn drain_result_subscriptions(&self)

fn handle_task(&self, active_request: ActiveTaskRequest)