ek-core 0.1.0

Business-agnostic plugin host and actor-over-bus runtime on top of ek-event: single-registry plugins, explicit deps with topological start, per-plugin actor workers, one-shot request/reply, panic quarantine, five-step close.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62

//! 错误体系:全部公共 API 的错误面。

use std::fmt;

/// 宿主注册/生命周期错误。
#[derive(Debug, Clone, PartialEq, Eq)]
pub enum PluginError {
    /// 插件名不合法(规则:首字母字母,其余 alnum/_/-,长度 1..=32)。
    IllegalName(String),
    /// 重名注册。
    Duplicate(String),
    /// deps 指向未注册目标。
    UnknownDep(String),
    /// start 时 deps 构成环(列出环上点名)。
    DepCycle(Vec<String>),
    /// get/remove 等操作目标不存在。
    UnknownName(String),
    /// 宿主已 start():停止接受 add_plugin。
    HostStarted,
    /// 宿主已 close():一切变更被拒。
    Stopped,
}

impl fmt::Display for PluginError {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        match self {
            Self::IllegalName(n) => write!(f, "illegal plugin name: {n:?}"),
            Self::Duplicate(n) => write!(f, "duplicate plugin: {n:?}"),
            Self::UnknownDep(n) => write!(f, "unknown dependency: {n:?}"),
            Self::DepCycle(c) => write!(f, "dependency cycle: {c:?}"),
            Self::UnknownName(n) => write!(f, "unknown plugin: {n:?}"),
            Self::HostStarted => write!(f, "host already started"),
            Self::Stopped => write!(f, "host closed"),
        }
    }
}
impl std::error::Error for PluginError {}

/// 请求应答(ask)错误。
#[derive(Debug, Clone, PartialEq, Eq)]
pub enum AskError {
    /// 目标 worker 未能在时限内回包(目标慢/挂/邮箱拥塞)。
    Timeout { target: String },
    /// 目标不存在/未 Running/已被检疫或移除(尽力而为的预检 + 断连快失败)。
    TargetGone { target: String },
    /// 回包/请求契约不匹配(错型信封),或 B 明确回 Err(InvalidPayload)。
    InvalidPayload { target: String },
    /// 总线已停(put 失败)。
    BusStopped,
}

impl fmt::Display for AskError {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        match self {
            Self::Timeout { target } => write!(f, "ask timeout: {target}"),
            Self::TargetGone { target } => write!(f, "ask target gone: {target}"),
            Self::InvalidPayload { target } => write!(f, "ask invalid payload/contract: {target}"),
            Self::BusStopped => write!(f, "bus stopped"),
        }
    }
}
impl std::error::Error for AskError {}