meerkat-mob 0.5.2

Multi-agent orchestration runtime for Meerkat
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

use serde::{Deserialize, Serialize};

/// Supported mob member provisioning backends.
#[derive(Debug, Clone, Copy, Default, PartialEq, Eq, Serialize, Deserialize)]
#[serde(rename_all = "snake_case")]
pub enum MobBackendKind {
    #[default]
    #[serde(rename = "session")]
    Session,
    External,
}

impl MobBackendKind {
    pub fn as_str(self) -> &'static str {
        match self {
            Self::Session => "session",
            Self::External => "external",
        }
    }
}

/// Concrete runtime binding for a specific member spawn.
///
/// [`MobBackendKind`] says *what kind* of backend (definition/profile level).
/// `RuntimeBinding` says *which specific runtime* (spawn/provision level).
///
/// First step toward identity-first mobs: the mob's roster is keyed by
/// identity ([`crate::MeerkatId`]). Everything in `RuntimeBinding` is a
/// hidden binding detail — how to reach the member's runtime, not who it is.
#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
#[serde(tag = "kind", rename_all = "snake_case")]
pub enum RuntimeBinding {
    /// Member runtime is a local session managed by the session service.
    Session,
    /// Member runtime is an external process with known comms identity.
    External {
        /// Real comms public key of the external process.
        peer_id: String,
        /// Real comms transport address of the external process.
        address: String,
    },
}

impl RuntimeBinding {
    /// Returns the backend kind tag for this binding.
    pub fn kind(&self) -> MobBackendKind {
        match self {
            Self::Session => MobBackendKind::Session,
            Self::External { .. } => MobBackendKind::External,
        }
    }
}