core package
Core infrastructure shared by every Stargazer microservice.
This package holds the runtime that gateway_main,
inference_main, agents_main, consolidation_main,
and web_main build on: the
StargazerService boot contract, the Redis
Streams event bus (RedisEventBus) and its
inbound/outbound consumers, the worker-side
ProxyPlatformAdapter, distributed
locking, trace/operation-state tracking, health probes, structured
logging, and the dead-letter queue.
Submodules
- core.checkpoint_media module
- core.checkpointed_effect module
- core.circuit_breaker module
- core.config_loader module
- core.control_ops module
- core.dependency_guards module
- core.distributed_lock module
- core.dlq module
DLQProjectionActionDLQProjectionResultDLQPublicationResultDLQSourceRetirementDLQProjectionErrorDLQReplayErrorDLQReplayConflictdlq_projection_ledger_key()dlq_replay_ledger_key()FailureDispositionclassify_failure_disposition()extract_stream_payload_bytes()extract_stream_aux_fields()DLQOutboxProjectorpublish_dlq_entry_idempotently()retire_failed_source()handle_failed_message()inspect_dlq_entry()replay_dlq_entry()
- core.durable_delayed_effects module
DelayedEffectStateDelayedEffectActionDelayedEffectAction.REGISTEREDDelayedEffectAction.CACHEDDelayedEffectAction.CONFLICTDelayedEffectAction.ACQUIREDDelayedEffectAction.RECLAIMEDDelayedEffectAction.BUSYDelayedEffectAction.NOT_DUEDelayedEffectAction.RENEWEDDelayedEffectAction.COMPLETEDDelayedEffectAction.DEFERREDDelayedEffectAction.RETRY_SCHEDULEDDelayedEffectAction.STALE_OWNERDelayedEffectAction.INVALID_STATEDelayedEffectAction.MISSING
DelayedEffectIntentDelayedEffectIntent.actionDelayedEffectIntent.stateDelayedEffectIntent.intent_idDelayedEffectIntent.operation_idDelayedEffectIntent.effect_typeDelayedEffectIntent.payload_fingerprintDelayedEffectIntent.payloadDelayedEffectIntent.due_at_msDelayedEffectIntent.created_at_msDelayedEffectIntent.owner_tokenDelayedEffectIntent.fenceDelayedEffectIntent.attemptsDelayedEffectIntent.receiptDelayedEffectIntent.errorDelayedEffectIntent.terminalDelayedEffectIntent.should_execute
DelayedEffectConflictDelayedEffectStoreDelayedEffectWorkerdelayed_effect_store_for_context()register_delayed_effect()
- core.event_bus module
- core.event_types module
- core.game_event_stream module
- core.gateway_pinned module
- core.gateway_rpc_ledger module
GatewayRpcLedgerGatewayRpcLedger.fingerprint()GatewayRpcLedger.operation_hash()GatewayRpcLedger.key_for()GatewayRpcLedger.reply_key_for()GatewayRpcLedger.claim()GatewayRpcLedger.begin()GatewayRpcLedger.renew()GatewayRpcLedger.complete()GatewayRpcLedger.fail()GatewayRpcLedger.mark_ambiguous()GatewayRpcLedger.get()
GatewayRpcDecisionGatewayRpcStateLedgerActionLedgerAction.ACQUIREDLedgerAction.RECLAIMEDLedgerAction.BUSYLedgerAction.BEGUNLedgerAction.ALREADY_EXECUTINGLedgerAction.RENEWEDLedgerAction.COMPLETEDLedgerAction.FAILEDLedgerAction.AMBIGUOUSLedgerAction.CACHEDLedgerAction.CONFLICTLedgerAction.STALE_OWNERLedgerAction.LEASE_EXPIREDLedgerAction.INVALID_STATELedgerAction.MISSINGLedgerAction.PROOF_EXPIREDLedgerAction.PROOF_HORIZON_UNSUPPORTED
LedgerRecordLedgerResultLedgerResult.actionLedgerResult.stateLedgerResult.operation_hashLedgerResult.requested_fingerprintLedgerResult.stored_fingerprintLedgerResult.fenceLedgerResult.owner_tokenLedgerResult.resultLedgerResult.errorLedgerResult.terminalLedgerResult.should_executeLedgerResult.statusLedgerResult.ownerLedgerResult.cached_result
canonical_payload_fingerprint()gateway_rpc_fingerprint()hashed_operation_suffix()validate_gateway_rpc_replay_horizon()
- core.health_server module
- core.ingress_ledger module
IngressPublishActionIngressLedgerErrorIngressPayloadConflictIngressPublishResultIngressPublishResult.actionIngressPublishResult.trace_idIngressPublishResult.stream_idIngressPublishResult.payload_fingerprintIngressPublishResult.identity_hashIngressPublishResult.trace_identity_hashIngressPublishResult.trace_keyIngressPublishResult.history_keyIngressPublishResult.active_keyIngressPublishResult.legacy_untrackedIngressPublishResult.lifecycle_expired
ingress_event_identity()is_ledger_eligible()canonical_ingress_trace_id()ingress_payload_fingerprint()IngressLedger
- core.lattice127 module
OrganLatticeViolationrequired_mask_for_fields()LatticeCellLatticeValidationLatticeValidation.active_cellsLatticeValidation.total_cellsLatticeValidation.hasse_edges_with_voidLatticeValidation.active_hasse_edgesLatticeValidation.rank_distributionLatticeValidation.unique_loopback_addressesLatticeValidation.all_addresses_loopbackLatticeValidation.closed_under_join_and_meet
LoopbackLattice127LoopbackLattice127.cellsLoopbackLattice127.active_cellsLoopbackLattice127.voidLoopbackLattice127.crownLoopbackLattice127.cell()LoopbackLattice127.join()LoopbackLattice127.meet()LoopbackLattice127.upper_covers()LoopbackLattice127.lower_covers()LoopbackLattice127.shadow_halo()LoopbackLattice127.hasse_edges()LoopbackLattice127.rank_distribution()LoopbackLattice127.field()LoopbackLattice127.sword_fieldLoopbackLattice127.sword_commit_fieldLoopbackLattice127.morphogenesis_fieldLoopbackLattice127.external_effect_fieldLoopbackLattice127.fusion_fieldLoopbackLattice127.canonical_spine()LoopbackLattice127.validate()
RecursiveLatticeAddressRecursiveLatticeAddress.pathRecursiveLatticeAddress.root()RecursiveLatticeAddress.repeated_crown()RecursiveLatticeAddress.depthRecursiveLatticeAddress.leafRecursiveLatticeAddress.local_ipRecursiveLatticeAddress.uriRecursiveLatticeAddress.binary_uriRecursiveLatticeAddress.recursive_notationRecursiveLatticeAddress.parentRecursiveLatticeAddress.descend()RecursiveLatticeAddress.is_ancestor_of()
RecursiveLoopbackLatticeLatticePolicy
- core.log_config module
- core.ops_exec module
- core.outbound_consumer module
- core.proxy_adapter module
ProxyPlatformAdapterProxyPlatformAdapter.__init__()ProxyPlatformAdapter.bind_effect_scope()ProxyPlatformAdapter.reset_effect_scope()ProxyPlatformAdapter.effect_scope_is_ambiguous()ProxyPlatformAdapter.send()ProxyPlatformAdapter.send_file()ProxyPlatformAdapter.send_with_buttons()ProxyPlatformAdapter.send_private_codex_authorization()ProxyPlatformAdapter.deliver_message_durable()ProxyPlatformAdapter.deliver_stream_chunk_durable()ProxyPlatformAdapter.edit_message_durable()ProxyPlatformAdapter.delete_message_durable()ProxyPlatformAdapter.bind_stream_messages_durable()ProxyPlatformAdapter.deliver_file_durable()ProxyPlatformAdapter.nameProxyPlatformAdapter.bot_identityProxyPlatformAdapter.send_typing()ProxyPlatformAdapter.start_typing()ProxyPlatformAdapter.stop_typing()ProxyPlatformAdapter.add_reaction()ProxyPlatformAdapter.set_presence()ProxyPlatformAdapter.fetch_history()ProxyPlatformAdapter.fetch_channel_history()ProxyPlatformAdapter.delegate_to_gateway()ProxyPlatformAdapter.should_skip_channel_heartbeat()ProxyPlatformAdapter.get_channel_name()
- core.redis_cluster_keys module
- core.remote_tool_registry module
AmbiguousRemoteToolResultDurableRemoteToolPendingDurableRemoteToolRejectedRemoteToolRegistryRemoteToolRegistry.start()RemoteToolRegistry.stop()RemoteToolRegistry.reload_catalog()RemoteToolRegistry.get_openai_tools()RemoteToolRegistry.get_openai_tools_by_names()RemoteToolRegistry.tool_names()RemoteToolRegistry.repeat_allowed_tools()RemoteToolRegistry.list_tools()RemoteToolRegistry.set_permissions()RemoteToolRegistry.is_allowed()RemoteToolRegistry.has_toolsRemoteToolRegistry.task_managerRemoteToolRegistry.call()RemoteToolRegistry.is_durable_replay_safe()RemoteToolRegistry.refresh_durable_replay_safety()
- core.resilience module
- core.serialization module
normalize_void_egregores()InboundEnvelopeModelInboundEnvelopeModel.channel_keyInboundEnvelopeModel.platformInboundEnvelopeModel.channel_idInboundEnvelopeModel.user_idInboundEnvelopeModel.usernameInboundEnvelopeModel.display_nameInboundEnvelopeModel.contentInboundEnvelopeModel.message_idInboundEnvelopeModel.timestampInboundEnvelopeModel.attachmentsInboundEnvelopeModel.reply_toInboundEnvelopeModel.embedsInboundEnvelopeModel.room_nameInboundEnvelopeModel.is_dmInboundEnvelopeModel.is_private_codex_dmInboundEnvelopeModel.guild_idInboundEnvelopeModel.member_rolesInboundEnvelopeModel.trace_idInboundEnvelopeModel.event_kindInboundEnvelopeModel.ingress_fingerprintInboundEnvelopeModel.enqueued_atInboundEnvelopeModel.is_addressedInboundEnvelopeModel.user_aliasesInboundEnvelopeModel.unified_user_idInboundEnvelopeModel.reactionsInboundEnvelopeModel.needle_shardInboundEnvelopeModel.babystar_playpenInboundEnvelopeModel.babystar_roomInboundEnvelopeModel.babystar_egregoresInboundEnvelopeModel.babystar_room_contextInboundEnvelopeModel.babystar_room_nameInboundEnvelopeModel.babystar_multiplayerInboundEnvelopeModel.babystar_reply_authorInboundEnvelopeModel.babystar_reply_excerptInboundEnvelopeModel.babystar_game_stateInboundEnvelopeModel.babystar_party_contextInboundEnvelopeModel.gock_hypervisorInboundEnvelopeModel.gock_group_idInboundEnvelopeModel.gock_roomInboundEnvelopeModel.gock_egregoreInboundEnvelopeModel.void_egregoresInboundEnvelopeModel.gock_auth_methodInboundEnvelopeModel.gock_wallet_addressInboundEnvelopeModel.gock_discord_user_idInboundEnvelopeModel.gock_token_balance_rawInboundEnvelopeModel.gock_token_decimalsInboundEnvelopeModel.gock_gate_passedInboundEnvelopeModel.gock_gate_checked_atInboundEnvelopeModel.gock_party_contextInboundEnvelopeModel.gock_market_snapshotsInboundEnvelopeModel.gock_universe_snapshotsInboundEnvelopeModel.gock_chart_queryInboundEnvelopeModel.gock_ecosystem_contextInboundEnvelopeModel.void_chain_verifiedInboundEnvelopeModel.void_trigger_idInboundEnvelopeModel.void_trigger_tx_hashInboundEnvelopeModel.void_trigger_log_indexInboundEnvelopeModel.void_lau_addressInboundEnvelopeModel.void_dss_addressInboundEnvelopeModel.void_soul_idInboundEnvelopeModel.void_recent_messagesInboundEnvelopeModel.void_reply_onchainInboundEnvelopeModel.model_config
OutboundEnvelopeModelOutboundEnvelopeModel.channel_idOutboundEnvelopeModel.platformOutboundEnvelopeModel.typeOutboundEnvelopeModel.textOutboundEnvelopeModel.file_dataOutboundEnvelopeModel.filenameOutboundEnvelopeModel.buttonsOutboundEnvelopeModel.message_idOutboundEnvelopeModel.emojiOutboundEnvelopeModel.message_keyOutboundEnvelopeModel.trace_idOutboundEnvelopeModel.processed_atOutboundEnvelopeModel.model_config
validate_inbound_envelope()validate_outbound_envelope()InboundEnvelopeInboundEnvelope.channel_keyInboundEnvelope.platformInboundEnvelope.channel_idInboundEnvelope.user_idInboundEnvelope.usernameInboundEnvelope.display_nameInboundEnvelope.contentInboundEnvelope.message_idInboundEnvelope.timestampInboundEnvelope.attachmentsInboundEnvelope.reply_toInboundEnvelope.embedsInboundEnvelope.room_nameInboundEnvelope.is_dmInboundEnvelope.is_private_codex_dmInboundEnvelope.guild_idInboundEnvelope.member_rolesInboundEnvelope.needle_shardInboundEnvelope.babystar_playpenInboundEnvelope.gock_hypervisorInboundEnvelope.gock_group_idInboundEnvelope.gock_roomInboundEnvelope.gock_egregoreInboundEnvelope.void_egregoresInboundEnvelope.gock_auth_methodInboundEnvelope.gock_wallet_addressInboundEnvelope.gock_discord_user_idInboundEnvelope.gock_token_balance_rawInboundEnvelope.gock_token_decimalsInboundEnvelope.gock_gate_passedInboundEnvelope.gock_gate_checked_atInboundEnvelope.gock_party_contextInboundEnvelope.gock_market_snapshotsInboundEnvelope.gock_universe_snapshotsInboundEnvelope.gock_chart_queryInboundEnvelope.gock_ecosystem_contextInboundEnvelope.void_chain_verifiedInboundEnvelope.void_trigger_idInboundEnvelope.void_trigger_tx_hashInboundEnvelope.void_trigger_log_indexInboundEnvelope.void_lau_addressInboundEnvelope.void_dss_addressInboundEnvelope.void_soul_idInboundEnvelope.void_recent_messagesInboundEnvelope.void_reply_onchainInboundEnvelope.trace_idInboundEnvelope.event_kindInboundEnvelope.ingress_fingerprintInboundEnvelope.enqueued_at
OutboundEnvelopeOutboundEnvelope.channel_idOutboundEnvelope.platformOutboundEnvelope.typeOutboundEnvelope.textOutboundEnvelope.file_dataOutboundEnvelope.filenameOutboundEnvelope.buttonsOutboundEnvelope.message_idOutboundEnvelope.emojiOutboundEnvelope.message_keyOutboundEnvelope.trace_idOutboundEnvelope.processed_at
serialize_stream_payload()deserialize_stream_payload()serialize_hash_field()deserialize_hash_field()
- core.service_base module
- core.service_registry module
- core.state_machine module
OperationStateMachineOperationStateMachine.anchor_streamOperationStateMachine.active_keyOperationStateMachine.is_valid_transition()OperationStateMachine.keys_for()OperationStateMachine.create()OperationStateMachine.ensure_queued()OperationStateMachine.transition_detailed()OperationStateMachine.transition()OperationStateMachine.heartbeat()OperationStateMachine.abandon_if_due()OperationStateMachine.checkpoint_and_transition()OperationStateMachine.terminal_ack()OperationStateMachine.dead_letter_ack()OperationStateMachine.terminal_reack()OperationStateMachine.get_record()
TraceKeysTraceLifecycleErrorTraceStateTraceState.RECEIVEDTraceState.PREPROCESSINGTraceState.QUEUEDTraceState.CLAIMEDTraceState.RECLAIMEDTraceState.PROCESSINGTraceState.PRE_INFERENCE_GATHERTraceState.INFERRINGTraceState.TOOL_EXECUTINGTraceState.POSTPROCESSINGTraceState.DELIVERINGTraceState.DELIVEREDTraceState.DEFERREDTraceState.CANCEL_REQUESTEDTraceState.ERROREDTraceState.RETRYINGTraceState.COMPLETEDTraceState.DEAD_LETTEREDTraceState.ABANDONEDTraceState.AMBIGUOUS
TransitionActionTransitionAction.CREATEDTransitionAction.APPLIEDTransitionAction.CACHEDTransitionAction.ALREADY_STATETransitionAction.HEARTBEATTransitionAction.NOT_DUETransitionAction.PROOF_LIVETransitionAction.MISSINGTransitionAction.CONFLICTTransitionAction.INVALID_STATETransitionAction.INVALID_PREDECESSORTransitionAction.INVALID_ARGUMENTTransitionAction.INVALID_TTLTransitionAction.METADATA_TOO_LARGETransitionAction.WRONGTYPETransitionAction.SCHEMA_CONFLICTTransitionAction.TERMINALTransitionAction.STALE_REVISIONTransitionAction.EXPIREDTransitionAction.ACK_REQUIREDTransitionAction.BINDING_MISSINGTransitionAction.BINDING_CONFLICT
TransitionResultattempt_counter_key()canonical_metadata_json()dead_letter_outbox_key()ingress_transition_id()recover_checkpoint()trace_keys()trace_keys_from_identity()transition_fingerprint()write_checkpoint_and_transition()
- core.stream_age module
- core.stream_consumer module
- core.structured_logger module
- core.tool_catalog module
- core.tool_session module
- core.tools_consumer module
- core.trace module
- core.turn_checkpoint module
ToolCallActionToolCallAction.ACQUIREDToolCallAction.RECLAIMEDToolCallAction.BUSYToolCallAction.BEGUNToolCallAction.ALREADY_EXECUTINGToolCallAction.RENEWEDToolCallAction.ABANDONEDToolCallAction.COMPLETEDToolCallAction.CACHEDToolCallAction.AMBIGUOUSToolCallAction.CONFLICTToolCallAction.STALE_OWNERToolCallAction.LEASE_EXPIREDToolCallAction.INVALID_STATEToolCallAction.MISSINGToolCallAction.SCHEMA_CONFLICT
ToolCallDecisionToolCallDecision.actionToolCallDecision.stateToolCallDecision.round_indexToolCallDecision.slot_indexToolCallDecision.operation_idToolCallDecision.provider_call_idToolCallDecision.tool_nameToolCallDecision.raw_argumentsToolCallDecision.owner_tokenToolCallDecision.fenceToolCallDecision.replay_safeToolCallDecision.resultToolCallDecision.payload_fingerprintToolCallDecision.should_beginToolCallDecision.should_executeToolCallDecision.terminalToolCallDecision.cached_result
ToolCallStateTurnCheckpointBusyTurnCheckpointConflictTurnCheckpointErrorTurnCheckpointSessionTurnCheckpointSession.scopeTurnCheckpointSession.keyTurnCheckpointSession.redisTurnCheckpointSession.trace_hashTurnCheckpointSession.execution_lease_secondsTurnCheckpointSession.ttl_secondsTurnCheckpointSession.load()TurnCheckpointSession.reconcile_lifecycle()TurnCheckpointSession.start()TurnCheckpointSession.reserve_assistant()TurnCheckpointSession.get_assistant()TurnCheckpointSession.logical_operation_id()TurnCheckpointSession.claim_tool()TurnCheckpointSession.begin_tool()TurnCheckpointSession.renew_tool()TurnCheckpointSession.abandon_tool()TurnCheckpointSession.complete_tool()TurnCheckpointSession.get_tool()TurnCheckpointSession.commit_round()TurnCheckpointSession.save_final_model()TurnCheckpointSession.reserve_final_delivery()TurnCheckpointSession.mark_delivered()TurnCheckpointSession.mark_completed()
TurnPhaseTurnSnapshotTurnSnapshot.phaseTurnSnapshot.messagesTurnSnapshot.tool_namesTurnSnapshot.runtimeTurnSnapshot.final_modelTurnSnapshot.final_textTurnSnapshot.final_deliveryTurnSnapshot.reply_message_keyTurnSnapshot.sent_message_idTurnSnapshot.completedTurnSnapshot.current_roundTurnSnapshot.revisionTurnSnapshot.input_fingerprintTurnSnapshot.assistant_responses