meerkat-runtime 0.4.10

v9 runtime control-plane for Meerkat agent lifecycle
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
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93

//! meerkat-runtime — v9 runtime control-plane for Meerkat agent lifecycle.
//!
//! This crate implements the runtime/control-plane layer of the v9 Canonical
//! Lifecycle specification. It sits between surfaces (CLI, RPC, REST, MCP)
//! and core (`meerkat-core`), managing:
//!
//! - Input acceptance, validation, and queueing
//! - InputState lifecycle tracking
//! - Policy resolution (what to do with each input)
//! - Runtime state machine (Idle ↔ Running ↔ Recovering → Stopped/Destroyed)
//! - Retire/respawn/reset lifecycle operations
//! - RuntimeEvent observability
//!
//! Core-facing types (RunPrimitive, RunEvent, CoreExecutor, etc.) live in
//! `meerkat-core::lifecycle`. This crate contains everything else.

#[cfg(target_arch = "wasm32")]
pub mod tokio {
    pub use tokio_with_wasm::alias::*;
}

#[cfg(not(target_arch = "wasm32"))]
pub use ::tokio;

pub mod accept;
pub mod coalescing;
pub mod comms_bridge;
pub mod comms_sink;
pub mod completion;
pub mod driver;
pub mod durability;
pub mod identifiers;
pub mod input;
pub mod input_ledger;
pub mod input_machine;
pub mod input_scope;
pub mod input_state;
pub mod lifecycle_ops;
pub mod mob_adapter;
pub mod policy;
pub mod policy_table;
pub mod queue;
pub mod runtime_event;
pub(crate) mod runtime_loop;
pub mod runtime_state;
pub mod service_ext;
pub mod session_adapter;
pub mod state_machine;
pub mod store;
pub mod traits;

// Re-exports for convenience
pub use accept::AcceptOutcome;
pub use coalescing::{
    AggregateDescriptor, CoalescingResult, SupersessionScope, apply_coalescing, apply_supersession,
    check_supersession, create_aggregate_input, is_coalescing_eligible,
};
pub use completion::{CompletionHandle, CompletionOutcome, CompletionRegistry};
pub use driver::{EphemeralRuntimeDriver, PersistentRuntimeDriver};
pub use durability::{DurabilityError, validate_durability};
pub use identifiers::{
    CausationId, ConversationId, CorrelationId, EventCodeId, IdempotencyKey, KindId,
    LogicalRuntimeId, PolicyVersion, ProjectionRuleId, RuntimeEventId, SchemaId, SupersessionKey,
};
pub use input::{
    ExternalEventInput, FlowStepInput, Input, InputDurability, InputHeader, InputOrigin,
    InputVisibility, PeerConvention, PeerInput, ProjectedInput, PromptInput, ResponseProgressPhase,
    ResponseTerminalStatus, SystemGeneratedInput,
};
pub use input_ledger::InputLedger;
pub use input_machine::{InputStateMachine, InputStateMachineError};
pub use input_scope::InputScope;
pub use input_state::{
    InputAbandonReason, InputLifecycleState, InputState, InputStateEvent, InputStateHistoryEntry,
    InputTerminalOutcome, PolicySnapshot, ReconstructionSource,
};
pub use lifecycle_ops::{abandon_non_terminal, would_abandon};
pub use policy::{ApplyMode, ConsumePoint, PolicyDecision, QueueMode, WakeMode};
pub use policy_table::{DEFAULT_POLICY_VERSION, DefaultPolicyTable};
pub use queue::InputQueue;
pub use runtime_event::{
    InputLifecycleEvent, RunLifecycleEvent, RuntimeEvent, RuntimeEventEnvelope,
    RuntimeProjectionEvent, RuntimeStateChangeEvent, RuntimeTopologyEvent,
};
pub use runtime_state::{RuntimeState, RuntimeStateTransitionError};
pub use service_ext::{RuntimeMode, SessionServiceRuntimeExt};
pub use session_adapter::RuntimeSessionAdapter;
pub use state_machine::RuntimeStateMachine;
pub use store::{InMemoryRuntimeStore, RuntimeStore, RuntimeStoreError, SessionDelta};
pub use traits::{
    DestroyReport, RecoveryReport, ResetReport, RespawnReport, RetireReport, RuntimeControlCommand,
    RuntimeControlPlane, RuntimeControlPlaneError, RuntimeDriver, RuntimeDriverError,
};