Struct MainEngine 

pub struct MainEngine { /* private fields */ }

Implementations

impl MainEngine

pub fn new(event: Option<Arc<EventEngine>>) -> Self

注入式创建:Some(bus) 复用外部引擎;None 自建(start() 时拉起)。

pub fn event_engine(&self) -> &Arc<EventEngine>

宿主级引擎句柄(测试/装配工具可用;插件不可见——ctx 不暴露)。

pub fn add_plugin( &self, plugin: Arc<impl Plugin + 'static>, ) -> Result<(), PluginError>

统一格式注册(名/D2、重名、同名自依赖、deps 存在性校验)。

pub fn get_state(&self, name: &str) -> Option<PluginState>

状态查询。

pub fn get_plugin(&self, name: &str) -> Option<PluginInfo>

信息快照。

pub fn get_typed<T: Plugin + 'static>(&self, name: &str) -> Option<Arc<T>>

类型安全获取(get_typed):同一分配的 Arc downcast。

pub fn plugin_names(&self) -> Vec<String>

注册名列表(注册序)。

pub fn mail_stats(&self, name: &str) -> Option<MailStats>

运行统计(溢出丢弃/panic 计数)。未注册 → None。

pub fn start(&self) -> Result<(), PluginError>

启动全部插件:总线 start → deps 拓扑序逐个装配 (on_init → 建邮箱 → spawn worker → state=Running → 注册 forwarder → on_start)。 依赖环 → DepCycle;重复 start 幂等 Ok;已 close → Stopped。

pub fn close(&self, timeout: Duration)

全局闭停:逆 start 序逐插件五步;然后清插件表。总线留给调用方(close_all 停总线)。

pub fn close_all(&self, timeout: Duration)

close + 停总线(终态)。

pub fn remove_plugin(&self, name: &str) -> Result<(), PluginError>

移除单个插件:Running 者执行五步(UNKNOWN 表项报错);仍被其他插件 deps 引用 时,eLog 警告(定稿 policy:允许移除 + 警告;依赖方后续 ask 走预检/断连失败)。