meerkat_mobkit/
lib.rs

1//! MobKit core — orchestration engine for the Meerkat multi-agent runtime.
2
3pub mod identity_first;
4
5pub mod access;
6pub mod auth;
7pub mod baseline;
8pub mod blob_store;
9pub mod config_convention;
10pub mod console_aggregator;
11pub mod console_config;
12pub mod console_contracts;
13pub(crate) mod console_spawn;
14pub mod contact_directory;
15pub mod decisions;
16pub mod gateway_wiring;
17pub mod governance;
18pub mod http_auth;
19pub mod http_console;
20pub mod http_flow_editor;
21pub mod http_sse;
22pub mod live_wiring;
23pub mod member_comms_id;
24pub mod memory;
25pub mod memory_wiring;
26pub mod mob_handle_runtime;
27pub mod mobpack;
28pub mod mocks;
29pub mod process;
30pub mod protocol;
31pub mod rpc;
32pub mod runtime;
33pub mod schedule_wiring;
34pub mod tool_compose;
35pub mod topology_control;
36pub mod types;
37pub mod unified_runtime;
38pub mod workgraph_admission;
39pub mod workgraph_wiring;
40
41pub use access::{
42    ACCESS_ACTIONS, AccessConfigError, AccessControlConfig, AccessController, AccessDecision,
43    AccessEffect, AccessGroup, AccessPrincipal, AccessResource, AccessRule, AccessView,
44    AgentResourceAttributes, evaluate_access, validate_access_config,
45};
46pub use auth::{
47    GATEWAY_PEER_KEY_FILE, GatewayPeerKeyError, GatewayPeerKeys, Jwk, JwksCache, JwksCacheConfig,
48    JwksCacheError, JwksDocument, JwtHeaderView, JwtValidationConfig, JwtValidationError,
49    OidcContractError, OidcDiscoveryDocument, PubkeyDecodeError, ValidatedJwt, decode_pubkey_b64,
50    extract_hs256_shared_secret, inspect_jwt_header, parse_jwks_json, parse_oidc_discovery_json,
51    select_jwk_for_token, validate_jwt_locally,
52};
53pub use baseline::{
54    BaselineVerificationError, BaselineVerificationReport, DEFAULT_MEERKAT_REPO,
55    REQUIRED_MEERKAT_SYMBOLS, verify_meerkat_baseline_symbols,
56};
57pub use blob_store::{
58    Base64BlobStoreAdapter, BinaryBlobPayload, BinaryBlobStore, BinaryBlobStoreAdapter,
59    ObjectStoreBlobStore,
60};
61pub use config_convention::ConventionalPaths;
62pub use console_aggregator::{
63    AllowAllConsoleVisibilityPolicy, AppendDisposition, AppendOutcome, ConsoleAggregatorOptions,
64    ConsoleCursor, ConsoleFrame, ConsoleFrameSource, ConsoleFrameSourceKind, ConsoleFrameStatus,
65    ConsoleIdentityInspection, ConsoleIdentityRecord,
66    ConsoleInteractionAccepted as ConsoleTimelineInteractionAccepted, ConsoleLogError,
67    ConsoleLogResult, ConsoleLogStore, ConsoleReplayUnavailable, ConsoleRuntimeRegistration,
68    ConsoleSendRequest, ConsoleTimelineEvent, ConsoleTimelineMode, ConsoleTimelinePage,
69    ConsoleTimelineQuery, ConsoleTimelineWindowPage, ConsoleTimelineWindowQuery, ConsoleVisibility,
70    ConsoleVisibilityPolicy, HideImplicitDelegateMembersConsoleVisibilityPolicy,
71    InMemoryConsoleLogStore, MobKitConsoleAggregator, NewConsoleFrame, ReplaySubscriptionEffect,
72    ReplaySubscriptionState, ReplaySubscriptionTransition, SendEffect, SendState, SendTransition,
73    SourceIngestionEffect, SourceIngestionState, SourceIngestionTransition, SqliteConsoleLogStore,
74};
75pub use console_config::{
76    ConsoleActionsUiConfig, ConsoleAgentBadgeConfig, ConsoleAgentListConfig,
77    ConsoleAgentSectionConfig, ConsoleAppearanceConfig, ConsoleBrandingConfig, ConsoleConfigError,
78    ConsoleEnvironmentConfig, ConsoleLayoutConfig, ConsoleRailFilterPresetConfig,
79    ConsoleRailUiConfig, ConsoleSidebarButtonConfig, ConsoleSidebarUiConfig, ConsoleUiConfig,
80    load_console_ui_config_from_path_for_realm, load_console_ui_config_from_toml,
81    load_console_ui_config_from_toml_for_realm,
82};
83pub use console_contracts::{
84    ConsoleIdentityEventEnvelope, ConsoleInteractionRejectedError, ReplayUnavailableError,
85};
86pub use decisions::{
87    AuthPolicy, AuthProvider, BigQueryNaming, ConsoleAccessRequest, ConsolePolicy,
88    DecisionPolicyError, MetricsPolicy, REQUIRED_RELEASE_TARGETS, ReleaseMetadata,
89    RuntimeOpsPolicy, enforce_console_route_access, load_trusted_mobkit_modules_from_toml,
90    parse_release_metadata_json, validate_bigquery_naming, validate_release_metadata,
91    validate_runtime_ops_policy,
92};
93#[allow(deprecated)]
94pub use governance::validate_phase0_governance_contracts;
95pub use governance::{
96    GovernanceValidationError, STRICT_TRACEABILITY_STATUSES, validate_governance_contracts,
97    validate_governance_state, validate_traceability_statuses,
98};
99pub use http_auth::{auth_middleware, with_auth_layer};
100pub use http_console::{
101    ConsoleJsonState, console_frontend_app_js_handler, console_frontend_index_handler,
102    console_frontend_router, console_json_handler, console_json_router,
103    console_json_router_with_aggregator, console_json_router_with_aggregator_and_access,
104    console_json_router_with_runtime,
105};
106pub use http_flow_editor::{
107    flow_editor_frontend_app_css_handler, flow_editor_frontend_app_js_handler,
108    flow_editor_frontend_index_handler, flow_editor_frontend_router,
109    flow_editor_frontend_vendor_js_handler, flow_editor_router,
110    flow_editor_router_with_host_deploy, flow_editor_rpc_handler,
111    flow_editor_rpc_handler_allowing_host_deploy, flow_editor_rpc_router,
112    flow_editor_rpc_router_allowing_host_deploy,
113};
114pub use http_sse::{
115    AgentEventSubscribeFn, MobEventSubscribeFn, agent_event_sse, agent_events_sse_router,
116    agent_events_sse_router_with_access, mob_events_sse_router, mob_events_sse_router_with_access,
117    mob_structural_events_sse_router, mob_structural_events_sse_router_with_access,
118};
119pub use identity_first::{
120    AgentMemoryConfig, AgentMemoryCustomizer, AgentMemoryError, AgentMemoryLlmWrites,
121    AgentMemoryOperatorScope, AgentMemoryPerTurnInjection, AgentMemoryProvider,
122    AgentMemoryRecallFailurePolicy, AgentMemoryRecallRequest, AgentMemoryRecord,
123    AgentMemoryRuntimeInjector, AgentMemorySelection, AuthoredWriteReceipt, MEMORY_TOOL_NAME,
124    MarkdownAgentMemoryStore, NewAgentMemory,
125};
126pub use memory::{
127    CompactionResetSink, ConsolePrincipalOperatorResolver, ContentTrustConfig, DistillCause,
128    DistillerConfig, DistillerEngine, DreamOutcome, DreamRun, HygieneCause, HygieneOutcome,
129    HygienistConfig, HygienistEngine, ManifestTier, MemberAgentEventSink, MemoryConflictBridge,
130    MemoryEventSink, MemoryGatingBridge, MemoryKind, MemoryRecord, MemoryScope,
131    MemorySpawnCustomizer, MemoryTimelineEvent, MobPurposeSource, NewMemoryRecord,
132    OperatorResolver, PromotionGateResolver, RecordMeta, SessionStoreEvidenceResolver,
133    SessionTaintTracker, SqliteAgentMemoryStore, StagedMemoryStore, StagedMutationBatch, StagedOp,
134    StewardConfig, StewardEngine, StewardTriggers, TaintLlmWriteGate, TaintObserverGuard,
135    TrustTier, spawn_member_event_observer, spawn_taint_observer,
136};
137pub use mob_handle_runtime::{
138    AfterCreateHook, CapabilityFlags, MobBootstrapOptions, MobBootstrapSpec, MobRuntime,
139    MobRuntimeError, RealMobRuntime, SessionCreatedContext, SessionHook, member_entry_to_json,
140    send_message_on_mob,
141};
142pub use mobpack::{
143    MOBPACK_MEDIA_TYPE, MOBPACK_SCHEMA_VERSION, MobpackDeployCommandResult, MobpackDiagnostic,
144    MobpackDocument, MobpackExportResult, MobpackValidationResult, deploy_command_preview,
145    export_mobpack, import_mobpack, mobpack_schema_response, validate_mobpack,
146};
147pub use mocks::{MockModuleProcess, MockProcessError};
148pub use process::{ProcessBoundaryError, run_process_json_line};
149pub use protocol::{ProtocolParseError, parse_module_event_line, parse_unified_event_line};
150pub use rpc::{
151    CONSOLE_TIMELINE_REPLAY_UNAVAILABLE_CODE, IdentityFirstContext, JsonRpcError, JsonRpcRequest,
152    JsonRpcResponse, MEMORY_BACKEND_UNAVAILABLE_CODE, MOB_EVENTS_STALE_CURSOR_CODE,
153    MOBKIT_CONTRACT_VERSION, handle_console_ingress_json, handle_mobkit_rpc_json,
154    handle_unified_rpc_json,
155};
156pub use rpc::{RpcCapabilities, RpcCapabilitiesError, parse_rpc_capabilities};
157pub use runtime::{
158    BaselineRuntimeError, BigQueryGcConfig, BigQuerySessionStoreAdapter, BigQuerySessionStoreError,
159    ConfigResolutionError, ConsoleAgentLiveSnapshot, ConsoleLiveSnapshot, ConsoleModelCapabilities,
160    ConsoleRestJsonRequest, ConsoleRestJsonResponse, DecisionRuntimeError,
161    ElephantMemoryBackendConfig, ElephantMemoryStoreError, GatingAuditEntry, GatingDecideError,
162    GatingDecideRequest, GatingDecision, GatingDecisionResult, GatingEvaluateRequest,
163    GatingEvaluateResult, GatingOutcome, GatingPendingEntry, GatingRiskTier, InMemoryMetadataStore,
164    JsonFileSessionStore, JsonFileSessionStoreError, JsonStoreLockRecord, LifecycleEvent,
165    LifecycleStage, LocalJsonMemoryBackendConfig, LocalJsonMemoryStoreError, McpBoundaryError,
166    MemoryAssertion, MemoryBackendConfig, MemoryConflictSignal, MemoryIndexError,
167    MemoryIndexRequest, MemoryIndexResult, MemoryQueryRequest, MemoryQueryResult, MemoryStoreInfo,
168    MetadataScope, MetadataStoreError, MobkitRuntimeError, MobkitRuntimeHandle, ModuleHealthState,
169    ModuleHealthTransition, ModuleRouteError, ModuleRouteRequest, ModuleRouteResponse,
170    NormalizationError, PersistentMetadataStore, RpcRouteError, RpcRuntimeError,
171    RuntimeBoundaryError, RuntimeDecisionInputs, RuntimeDecisionState, RuntimeFromConfigError,
172    RuntimeMetadataTable, RuntimeMutationError, RuntimeOptions, RuntimeRoute,
173    RuntimeRouteMutationError, RuntimeShutdownReport, ScheduleDefinition, ScheduleDispatch,
174    ScheduleDispatchReport, ScheduleEvaluation, ScheduleRuntimeInjection, ScheduleTrigger,
175    SchedulingSupervisorSignal, SessionPersistenceRow, SessionStoreContract, SessionStoreKind,
176    SqliteMetadataStore, SubscribeRequest, SubscribeResponse, SubscribeScope, SupervisorReport,
177    TrustedOidcRuntimeConfig, WILDCARD_ROUTE, build_runtime_decision_state,
178    evaluate_schedules_at_tick, handle_console_rest_json_route,
179    handle_console_rest_json_route_with_snapshot,
180    handle_console_rest_json_route_with_snapshot_and_access, materialize_latest_session_rows,
181    materialize_live_session_rows, normalize_event_line, route_module_call,
182    route_module_call_rpc_json, route_module_call_rpc_subprocess, run_discovered_module_once,
183    run_meerkat_baseline_verification_once, run_module_boundary_once,
184    run_rpc_capabilities_boundary_once, session_store_contracts, start_mobkit_runtime,
185    start_mobkit_runtime_with_options,
186};
187pub use topology_control::{
188    SameProcessTopologyCoordinator, TopologyAction, TopologyApplyRequest,
189    TopologyBilateralApplyRequest, TopologyBilateralPlan, TopologyBilateralPlanRequest,
190    TopologyBilateralSnapshot, TopologyBootstrapConfig, TopologyControlError, TopologyControlMode,
191    TopologyControlPolicy, TopologyController, TopologyEdge, TopologyEdgeResult,
192    TopologyEdgeResultStatus, TopologyEdgeSnapshot, TopologyEndpoint, TopologyMutation,
193    TopologyNodeAffordances, TopologyNodeSnapshot, TopologyOperationReceipt,
194    TopologyOperationRecord, TopologyOperationRecordStatus, TopologyOperationStatus, TopologyPlan,
195    TopologyPlanRequest, TopologyPlannedEdge, TopologyRevisionTransition, TopologyRuntimeHandle,
196    TopologySnapshot,
197};
198pub use types::{
199    AgentDiscoverySpec, DiscoverySpec, EventEnvelope, MobKitConfig, MobStructuralEventEnvelope,
200    ModuleConfig, ModuleEvent, PreSpawnData, RestartPolicy, UnifiedEvent,
201};
202pub use unified_runtime::{
203    DEFAULT_REFERENCE_APP_MAX_CONCURRENT_REQUESTS, DesiredPeerEdge, DesiredPeerEdgeError,
204    Discovery, EdgeDiscovery, EdgeReconcileFailure, ErrorEvent, ErrorHook, EventLogConfig,
205    EventLogStore, EventQuery, IdentityBootstrapMode, PersistedEvent, PostReconcileHook,
206    PostSpawnHook, PreSpawnContext, PreSpawnHook, RediscoverReport, ShutdownDrainReport,
207    UnifiedRuntime, UnifiedRuntimeBootstrapError, UnifiedRuntimeBuilder,
208    UnifiedRuntimeBuilderError, UnifiedRuntimeBuilderField, UnifiedRuntimeError,
209    UnifiedRuntimeReconcileEdgesReport, UnifiedRuntimeReconcileError,
210    UnifiedRuntimeReconcileReport, UnifiedRuntimeReconcileRoutingReport, UnifiedRuntimeRunReport,
211    UnifiedRuntimeShutdownReport, discovery_spec_to_spawn_spec,
212};
meerkat_mobkit/lib.rs

meerkat_mobkit/
lib.rs
