Skip to main content

Module runtime

Module runtime 

Source
Expand description

Runtime subsystem types — routing, delivery, gating, memory, scheduling, and session persistence.

Re-exports§

pub use metadata::InMemoryMetadataStore;
pub use metadata::LabelRpcResult;
pub use metadata::MetadataScope;
pub use metadata::MetadataStoreError;
pub use metadata::PersistentMetadataStore;
pub use metadata::RuntimeMetadataTable;
pub use metadata::SqliteMetadataStore;
pub use metadata::dispatch_labels_delete;
pub use metadata::dispatch_labels_get;
pub use metadata::dispatch_labels_set;
pub use metadata::labels_to_json_value;
pub use metadata::parse_labels_param;
pub use metadata::parse_run_id_param;

Modules§

cross_mob_control
Cross-mob control protocol — Phase 2 of the cross-mob transport story.
cross_mob_remote
Cross-mob remote-handle proxy.
metadata
Mobkit-side sidecar table for mob- and run-level labels.

Structs§

BigQueryGcConfig
BigQuerySessionStoreAdapter
ConsoleAgentLiveSnapshot
ConsoleLiveSnapshot
ConsoleMember
Console-facing view of a single mob member.
ConsoleModelCapabilities
ConsoleRestJsonRequest
ConsoleRestJsonResponse
DeliveryAttempt
DeliveryHistoryRequest
DeliveryHistoryResponse
DeliveryRecord
DeliverySendRequest
ElephantMemoryBackendConfig
GatingAuditEntry
GatingDecideRequest
GatingDecisionResult
GatingEvaluateRequest
GatingEvaluateResult
GatingPendingEntry
JsonFileSessionStore
JsonStoreLockRecord
LifecycleEvent
MemoryAssertion
MemoryConflictSignal
MemoryIndexRequest
MemoryIndexResult
MemoryQueryRequest
MemoryQueryResult
MemoryStoreInfo
MobkitRuntimeHandle
ModuleHealthTransition
ModuleRouteRequest
ModuleRouteResponse
RoutingResolution
RoutingResolveRequest
RuntimeDecisionInputs
RuntimeDecisionState
RuntimeOptions
RuntimeRoute
RuntimeShutdownReport
ScheduleDefinition
ScheduleDispatch
ScheduleDispatchReport
ScheduleEvaluation
ScheduleRuntimeInjection
ScheduleTrigger
SchedulingSupervisorSignal
SessionPersistenceRow
SessionStoreContract
SubscribeKeepAlive
SubscribeRequest
SubscribeResponse
SupervisorReport
TrustedOidcRuntimeConfig

Enums§

BaselineRuntimeError
BigQuerySessionStoreError
ConfigResolutionError
DecisionRuntimeError
DeliverySendError
ElephantMemoryStoreError
GatingDecideError
GatingDecision
GatingOutcome
GatingRiskTier
JsonFileSessionStoreError
LifecycleStage
McpBoundaryError
MemoryBackendConfig
MemoryIndexError
MobkitRuntimeError
ModuleHealthState
ModuleRouteError
NormalizationError
RoutingResolveError
RpcRouteError
RpcRuntimeError
RuntimeBoundaryError
RuntimeFromConfigError
RuntimeMutationError
RuntimeRouteMutationError
ScheduleValidationError
SessionStoreKind
SubscribeError
SubscribeScope

Constants§

ROUTING_RETRY_MAX_CAP
WILDCARD_ROUTE

Functions§

build_runtime_decision_state
evaluate_schedules_at_tick
extract_bearer_token_from_header
Extract a bearer token from an Authorization: Bearer <token> header value.
handle_console_rest_json_route
handle_console_rest_json_route_with_snapshot
handle_console_rest_json_route_with_snapshot_and_access
Access-aware variant of handle_console_rest_json_route_with_snapshot.
materialize_latest_session_rows
materialize_live_session_rows
normalize_event_line
route_module_call
route_module_call_rpc_json
route_module_call_rpc_subprocess
run_discovered_module_once
run_meerkat_baseline_verification_once
run_module_boundary_once
run_periodic_gc
run_periodic_gc_with_error_callback
run_rpc_capabilities_boundary_once
session_store_contracts
start_mobkit_runtime
start_mobkit_runtime_with_options
validate_console_token
Validate a bearer token against the console’s trusted OIDC config AND the email allowlist / provider policy (via enforce_console_route_access). Returns true only if the token is valid AND the caller is authorized.

Type Aliases§

GcErrorCallback
Callback for GC error reporting. Receives the error message.