meerkat-mobkit 0.8.22

Companion orchestration platform for the Meerkat multi-agent runtime
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

//! Identity-first continuity types and contracts for MobKit.

pub mod adapters;
pub mod agent_memory;
pub mod bridge;
pub mod contracts;
pub mod gateway_bridges;
pub mod local_lease;
pub mod local_store;
pub mod orchestrator;
pub mod runtime;
mod types;

pub use adapters::{
    ContinuityIncrementalSessionStore, ContinuitySessionStoreAdapter, DiscoveryRosterAdapter,
    EdgeDiscoveryTopologyAdapter, MutableRosterProvider, SessionHookCustomizerAdapter,
    SessionRuntimeState, agent_discovery_to_durable,
};
pub use agent_memory::{
    AgentMemoryConfig, AgentMemoryCustomizer, AgentMemoryError, AgentMemoryForgetResult,
    AgentMemoryLlmWrites, AgentMemoryOperatorScope, AgentMemoryPerTurnInjection,
    AgentMemoryProvider, AgentMemoryRecallFailurePolicy, AgentMemoryRecallRequest,
    AgentMemoryRecord, AgentMemoryRuntimeInjector, AgentMemorySelection, AuthoredWriteReceipt,
    MEMORY_TOOL_NAME, NewAgentMemory,
};
pub use bridge::{
    BridgeAdmissionError, BridgeDelivery, BridgeError, BridgeTurnError, BridgeTurnReceipt,
    CommittedBoundaryRecoverer, CommittedBoundaryRepair, CompactionFloorRegistry, MemberInspection,
    MobSessionBridge, ResumeFallbackReason, ResumeRejectionKind, ResumeSessionOutcome,
    SessionBridge,
};
pub use contracts::*;
pub use gateway_bridges::{
    CallbackBridge, GatewayAgentCustomizer, GatewayContinuityStore, GatewayLeaseProvider,
    GatewayRosterProvider, GatewayTopologyProvider,
};
pub use local_lease::LocalLeaseProvider;
pub use local_store::{
    HEAD_CANONICAL_SCHEMA_VERSION as HEAD_CANONICAL_CONTINUITY_SCHEMA_VERSION, LocalContinuityStore,
};
pub use orchestrator::{
    ReconcileAction, RestoreFlowResult, RestoreOutcome, compute_reconcile_actions,
    lazy_register_flow, restore_flow,
};
pub use runtime::{
    ContinuityRepairPolicy, IdentityFirstRuntimeContext, IdentityRuntime, IdentityRuntimeConfig,
    IdentityRuntimeError, wire_cross_mob_by_identity,
};
pub use types::*;