meerkat_mobkit/
lib.rs

1//! MobKit core — orchestration engine for the Meerkat multi-agent runtime.
2
3pub mod identity_first;
4
5pub mod auth;
6pub mod baseline;
7pub mod blob_store;
8pub mod config_convention;
9pub mod console_aggregator;
10pub mod console_config;
11pub mod console_contracts;
12pub mod contact_directory;
13pub mod decisions;
14pub mod governance;
15pub mod http_auth;
16pub mod http_console;
17pub mod http_sse;
18pub mod mob_handle_runtime;
19pub mod mocks;
20pub mod process;
21pub mod protocol;
22pub mod rpc;
23pub mod runtime;
24pub mod types;
25pub mod unified_runtime;
26
27pub use auth::{
28    GATEWAY_PEER_KEY_FILE, GatewayPeerKeyError, GatewayPeerKeys, Jwk, JwksCache, JwksCacheConfig,
29    JwksCacheError, JwksDocument, JwtHeaderView, JwtValidationConfig, JwtValidationError,
30    OidcContractError, OidcDiscoveryDocument, PubkeyDecodeError, ValidatedJwt, decode_pubkey_b64,
31    extract_hs256_shared_secret, inspect_jwt_header, parse_jwks_json, parse_oidc_discovery_json,
32    select_jwk_for_token, validate_jwt_locally,
33};
34pub use baseline::{
35    BaselineVerificationError, BaselineVerificationReport, DEFAULT_MEERKAT_REPO,
36    REQUIRED_MEERKAT_SYMBOLS, verify_meerkat_baseline_symbols,
37};
38pub use blob_store::{
39    Base64BlobStoreAdapter, BinaryBlobPayload, BinaryBlobStore, BinaryBlobStoreAdapter,
40    ObjectStoreBlobStore,
41};
42pub use config_convention::ConventionalPaths;
43pub use console_aggregator::{
44    AllowAllConsoleVisibilityPolicy, AppendDisposition, AppendOutcome, ConsoleAggregatorOptions,
45    ConsoleCursor, ConsoleFrame, ConsoleFrameSource, ConsoleFrameSourceKind, ConsoleFrameStatus,
46    ConsoleIdentityInspection, ConsoleIdentityRecord,
47    ConsoleInteractionAccepted as ConsoleTimelineInteractionAccepted, ConsoleLogError,
48    ConsoleLogResult, ConsoleLogStore, ConsoleReplayUnavailable, ConsoleRuntimeRegistration,
49    ConsoleSendRequest, ConsoleTimelineEvent, ConsoleTimelineMode, ConsoleTimelinePage,
50    ConsoleTimelineQuery, ConsoleTimelineWindowPage, ConsoleTimelineWindowQuery, ConsoleVisibility,
51    ConsoleVisibilityPolicy, HideImplicitDelegateMembersConsoleVisibilityPolicy,
52    InMemoryConsoleLogStore, MobKitConsoleAggregator, NewConsoleFrame, ReplaySubscriptionEffect,
53    ReplaySubscriptionState, ReplaySubscriptionTransition, SendEffect, SendState, SendTransition,
54    SourceIngestionEffect, SourceIngestionState, SourceIngestionTransition, SqliteConsoleLogStore,
55};
56pub use console_config::{
57    ConsoleActionsUiConfig, ConsoleAgentBadgeConfig, ConsoleAgentListConfig,
58    ConsoleAgentSectionConfig, ConsoleAppearanceConfig, ConsoleBrandingConfig, ConsoleConfigError,
59    ConsoleEnvironmentConfig, ConsoleLayoutConfig, ConsoleRailFilterPresetConfig,
60    ConsoleRailUiConfig, ConsoleSidebarButtonConfig, ConsoleSidebarUiConfig, ConsoleUiConfig,
61    load_console_ui_config_from_path_for_realm, load_console_ui_config_from_toml,
62    load_console_ui_config_from_toml_for_realm,
63};
64pub use console_contracts::{
65    ConsoleIdentityEventEnvelope, ConsoleInteractionRejectedError, ReplayUnavailableError,
66};
67pub use decisions::{
68    AuthPolicy, AuthProvider, BigQueryNaming, ConsoleAccessRequest, ConsolePolicy,
69    DecisionPolicyError, MetricsPolicy, REQUIRED_RELEASE_TARGETS, ReleaseMetadata,
70    RuntimeOpsPolicy, enforce_console_route_access, load_trusted_mobkit_modules_from_toml,
71    parse_release_metadata_json, validate_bigquery_naming, validate_release_metadata,
72    validate_runtime_ops_policy,
73};
74#[allow(deprecated)]
75pub use governance::validate_phase0_governance_contracts;
76pub use governance::{
77    GovernanceValidationError, STRICT_TRACEABILITY_STATUSES, validate_governance_contracts,
78    validate_governance_state, validate_traceability_statuses,
79};
80pub use http_auth::{auth_middleware, with_auth_layer};
81pub use http_console::{
82    ConsoleJsonState, console_frontend_app_js_handler, console_frontend_index_handler,
83    console_frontend_router, console_json_handler, console_json_router,
84    console_json_router_with_aggregator, console_json_router_with_runtime,
85};
86pub use http_sse::{
87    AgentEventSubscribeFn, MobEventSubscribeFn, agent_event_sse, agent_events_sse_router,
88    mob_events_sse_router, mob_structural_events_sse_router,
89};
90pub use mob_handle_runtime::{
91    AfterCreateHook, CapabilityFlags, MobBootstrapOptions, MobBootstrapSpec, MobRuntime,
92    MobRuntimeError, RealMobRuntime, SessionCreatedContext, SessionHook, member_entry_to_json,
93    send_message_on_mob,
94};
95pub use mocks::{MockModuleProcess, MockProcessError};
96pub use process::{ProcessBoundaryError, run_process_json_line};
97pub use protocol::{ProtocolParseError, parse_module_event_line, parse_unified_event_line};
98pub use rpc::{
99    CONSOLE_TIMELINE_REPLAY_UNAVAILABLE_CODE, IdentityFirstContext, JsonRpcError, JsonRpcRequest,
100    JsonRpcResponse, MEMORY_BACKEND_UNAVAILABLE_CODE, MOB_EVENTS_STALE_CURSOR_CODE,
101    MOBKIT_CONTRACT_VERSION, handle_console_ingress_json, handle_mobkit_rpc_json,
102    handle_unified_rpc_json,
103};
104pub use rpc::{RpcCapabilities, RpcCapabilitiesError, parse_rpc_capabilities};
105pub use runtime::{
106    BaselineRuntimeError, BigQueryGcConfig, BigQuerySessionStoreAdapter, BigQuerySessionStoreError,
107    ConfigResolutionError, ConsoleAgentLiveSnapshot, ConsoleLiveSnapshot, ConsoleModelCapabilities,
108    ConsoleRestJsonRequest, ConsoleRestJsonResponse, DecisionRuntimeError,
109    ElephantMemoryBackendConfig, ElephantMemoryStoreError, GatingAuditEntry, GatingDecideError,
110    GatingDecideRequest, GatingDecision, GatingDecisionResult, GatingEvaluateRequest,
111    GatingEvaluateResult, GatingOutcome, GatingPendingEntry, GatingRiskTier, InMemoryMetadataStore,
112    JsonFileSessionStore, JsonFileSessionStoreError, JsonStoreLockRecord, LifecycleEvent,
113    LifecycleStage, McpBoundaryError, MemoryAssertion, MemoryBackendConfig, MemoryConflictSignal,
114    MemoryIndexError, MemoryIndexRequest, MemoryIndexResult, MemoryQueryRequest, MemoryQueryResult,
115    MemoryStoreInfo, MetadataScope, MetadataStoreError, MobkitRuntimeError, MobkitRuntimeHandle,
116    ModuleHealthState, ModuleHealthTransition, ModuleRouteError, ModuleRouteRequest,
117    ModuleRouteResponse, NormalizationError, PersistentMetadataStore, RpcRouteError,
118    RpcRuntimeError, RuntimeBoundaryError, RuntimeDecisionInputs, RuntimeDecisionState,
119    RuntimeFromConfigError, RuntimeMetadataTable, RuntimeMutationError, RuntimeOptions,
120    RuntimeRoute, RuntimeRouteMutationError, RuntimeShutdownReport, ScheduleDefinition,
121    ScheduleDispatch, ScheduleDispatchReport, ScheduleEvaluation, ScheduleRuntimeInjection,
122    ScheduleTrigger, SchedulingSupervisorSignal, SessionPersistenceRow, SessionStoreContract,
123    SessionStoreKind, SqliteMetadataStore, SubscribeRequest, SubscribeResponse, SubscribeScope,
124    SupervisorReport, TrustedOidcRuntimeConfig, WILDCARD_ROUTE, build_runtime_decision_state,
125    evaluate_schedules_at_tick, handle_console_rest_json_route,
126    handle_console_rest_json_route_with_snapshot, materialize_latest_session_rows,
127    materialize_live_session_rows, normalize_event_line, route_module_call,
128    route_module_call_rpc_json, route_module_call_rpc_subprocess, run_discovered_module_once,
129    run_meerkat_baseline_verification_once, run_module_boundary_once,
130    run_rpc_capabilities_boundary_once, session_store_contracts, start_mobkit_runtime,
131    start_mobkit_runtime_with_options,
132};
133pub use types::{
134    AgentDiscoverySpec, DiscoverySpec, EventEnvelope, MobKitConfig, MobStructuralEventEnvelope,
135    ModuleConfig, ModuleEvent, PreSpawnData, RestartPolicy, UnifiedEvent,
136};
137pub use unified_runtime::{
138    DEFAULT_REFERENCE_APP_MAX_CONCURRENT_REQUESTS, DesiredPeerEdge, DesiredPeerEdgeError,
139    Discovery, EdgeDiscovery, EdgeReconcileFailure, ErrorEvent, ErrorHook, EventLogConfig,
140    EventLogStore, EventQuery, IdentityBootstrapMode, PersistedEvent, PostReconcileHook,
141    PostSpawnHook, PreSpawnContext, PreSpawnHook, RediscoverReport, ShutdownDrainReport,
142    UnifiedRuntime, UnifiedRuntimeBootstrapError, UnifiedRuntimeBuilder,
143    UnifiedRuntimeBuilderError, UnifiedRuntimeBuilderField, UnifiedRuntimeError,
144    UnifiedRuntimeReconcileEdgesReport, UnifiedRuntimeReconcileError,
145    UnifiedRuntimeReconcileReport, UnifiedRuntimeReconcileRoutingReport, UnifiedRuntimeRunReport,
146    UnifiedRuntimeShutdownReport, discovery_spec_to_spawn_spec,
147};
meerkat_mobkit/lib.rs

meerkat_mobkit/
lib.rs
