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.circuit_breaker module
  • CircuitBreakerOpenException
  • CircuitBreaker
    • CircuitBreaker.__init__()
    • CircuitBreaker.call()
• core.config_loader module
  • load_and_validate()
• core.control_ops module
  • control_op_for()
  • is_control_ops_command()
  • unit_name_for()
  • fleet_units()
  • ControlOpsDaemon
    • ControlOpsDaemon.run()
  • dispatch_control_op()
  • format_service_roster()
• core.dependency_guards module
  • guard_async_dependency()
• core.distributed_lock module
  • DistributedLock
    • DistributedLock.__init__()
    • DistributedLock.keys_released_count()
    • DistributedLock.acquire()
    • DistributedLock.release()
    • DistributedLock.acquire_blocking()
    • DistributedLock.__aenter__()
    • DistributedLock.__aexit__()
  • FencedKGWriter
    • FencedKGWriter.__init__()
    • FencedKGWriter.token
    • FencedKGWriter.write()
• core.dlq module
  • extract_stream_payload_bytes()
  • extract_stream_aux_fields()
  • handle_failed_message()
  • inspect_dlq_entry()
  • replay_dlq_entry()
• core.event_bus module
  • RedisEventBus
    • RedisEventBus.__init__()
    • RedisEventBus.ensure_streams()
    • RedisEventBus.publish_inbound()
    • RedisEventBus.publish_outbound()
    • RedisEventBus.publish_tools_request()
    • RedisEventBus.publish_tools_reply()
    • RedisEventBus.get_stream_info()
    • RedisEventBus.get_pending_count()
• core.event_types module
  • EventEnvelope
    • EventEnvelope.event_id
    • EventEnvelope.event_type
    • EventEnvelope.source_service
    • EventEnvelope.source_instance
    • EventEnvelope.trace_id
    • EventEnvelope.timestamp
    • EventEnvelope.payload
    • EventEnvelope.data
    • EventEnvelope.retry_count
    • EventEnvelope.schema_version
  • deserialize_envelope()
• core.gateway_pinned module
  • GATEWAY_PINNED_TOOLS
  • INFERENCE_PINNED_TOOLS
• core.health_server module
  • HealthServer
    • HealthServer.__init__()
    • HealthServer.healthz()
    • HealthServer.readyz()
    • HealthServer.start()
    • HealthServer.stop()
• core.log_config module
  • StructuredFormatter
    • StructuredFormatter.format()
  • configure_logging()
• core.ops_exec module
  • systemctl_restart()
  • PullResult
    • PullResult.ran
    • PullResult.ok
    • PullResult.summary
  • run_git_pull()
• core.outbound_consumer module
  • OutboundStreamConsumer
    • OutboundStreamConsumer.__init__()
    • OutboundStreamConsumer.start()
    • OutboundStreamConsumer.stop()
• core.proxy_adapter module
  • ProxyPlatformAdapter
    • ProxyPlatformAdapter.__init__()
    • ProxyPlatformAdapter.send()
    • ProxyPlatformAdapter.send_file()
    • ProxyPlatformAdapter.send_with_buttons()
    • ProxyPlatformAdapter.name
    • ProxyPlatformAdapter.bot_identity
    • ProxyPlatformAdapter.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.remote_tool_registry module
  • RemoteToolRegistry
    • RemoteToolRegistry.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_tools
    • RemoteToolRegistry.task_manager
    • RemoteToolRegistry.call()
• core.resilience module
  • RedisCircuitBreaker
    • RedisCircuitBreaker.__init__()
    • RedisCircuitBreaker.state
    • RedisCircuitBreaker.failures
    • RedisCircuitBreaker.execute()
    • RedisCircuitBreaker.flush_re_sync_queue()
  • ResilientRedis
    • ResilientRedis.__init__()
    • ResilientRedis.__getattr__()
• core.serialization module
  • InboundEnvelopeModel
    • InboundEnvelopeModel.channel_key
    • InboundEnvelopeModel.platform
    • InboundEnvelopeModel.channel_id
    • InboundEnvelopeModel.user_id
    • InboundEnvelopeModel.username
    • InboundEnvelopeModel.display_name
    • InboundEnvelopeModel.content
    • InboundEnvelopeModel.message_id
    • InboundEnvelopeModel.timestamp
    • InboundEnvelopeModel.attachments
    • InboundEnvelopeModel.reply_to
    • InboundEnvelopeModel.embeds
    • InboundEnvelopeModel.room_name
    • InboundEnvelopeModel.is_dm
    • InboundEnvelopeModel.guild_id
    • InboundEnvelopeModel.member_roles
    • InboundEnvelopeModel.trace_id
    • InboundEnvelopeModel.enqueued_at
    • InboundEnvelopeModel.is_addressed
    • InboundEnvelopeModel.strangler_route
    • InboundEnvelopeModel.user_aliases
    • InboundEnvelopeModel.unified_user_id
    • InboundEnvelopeModel.reactions
    • InboundEnvelopeModel.model_config
  • OutboundEnvelopeModel
    • OutboundEnvelopeModel.channel_id
    • OutboundEnvelopeModel.platform
    • OutboundEnvelopeModel.type
    • OutboundEnvelopeModel.text
    • OutboundEnvelopeModel.file_data
    • OutboundEnvelopeModel.filename
    • OutboundEnvelopeModel.buttons
    • OutboundEnvelopeModel.message_id
    • OutboundEnvelopeModel.emoji
    • OutboundEnvelopeModel.message_key
    • OutboundEnvelopeModel.trace_id
    • OutboundEnvelopeModel.processed_at
    • OutboundEnvelopeModel.model_config
  • validate_inbound_envelope()
  • validate_outbound_envelope()
  • InboundEnvelope
    • InboundEnvelope.channel_key
    • InboundEnvelope.platform
    • InboundEnvelope.channel_id
    • InboundEnvelope.user_id
    • InboundEnvelope.username
    • InboundEnvelope.display_name
    • InboundEnvelope.content
    • InboundEnvelope.message_id
    • InboundEnvelope.timestamp
    • InboundEnvelope.attachments
    • InboundEnvelope.reply_to
    • InboundEnvelope.embeds
    • InboundEnvelope.room_name
    • InboundEnvelope.is_dm
    • InboundEnvelope.guild_id
    • InboundEnvelope.member_roles
    • InboundEnvelope.trace_id
    • InboundEnvelope.enqueued_at
  • OutboundEnvelope
    • OutboundEnvelope.channel_id
    • OutboundEnvelope.platform
    • OutboundEnvelope.type
    • OutboundEnvelope.text
    • OutboundEnvelope.file_data
    • OutboundEnvelope.filename
    • OutboundEnvelope.buttons
    • OutboundEnvelope.message_id
    • OutboundEnvelope.emoji
    • OutboundEnvelope.message_key
    • OutboundEnvelope.trace_id
    • OutboundEnvelope.processed_at
  • serialize_stream_payload()
  • deserialize_stream_payload()
  • serialize_hash_field()
  • deserialize_hash_field()
• core.service_base module
  • StargazerService
    • StargazerService.__init__()
    • StargazerService.boot()
    • StargazerService.shutdown()
    • StargazerService.on_start()
    • StargazerService.run()
    • StargazerService.on_stop()
• core.service_registry module
  • register_service()
  • heartbeat()
  • deregister_service()
• core.state_machine module
  • OperationStateMachine
    • OperationStateMachine.is_valid_transition()
    • OperationStateMachine.__init__()
    • OperationStateMachine.transition()
  • write_checkpoint_and_transition()
  • recover_checkpoint()
• core.strangler_router module
  • StranglerRouter
    • StranglerRouter.__init__()
    • StranglerRouter.start()
    • StranglerRouter.stop()
    • StranglerRouter.get_route()
• core.stream_consumer module
  • InboundStreamConsumer
    • InboundStreamConsumer.__init__()
    • InboundStreamConsumer.start()
    • InboundStreamConsumer.stop()
  • OutboundStreamConsumer
    • OutboundStreamConsumer.__init__()
    • OutboundStreamConsumer.start()
    • OutboundStreamConsumer.stop()
• core.structured_logger module
  • JSONFormatter
    • JSONFormatter.__init__()
    • JSONFormatter.format()
  • configure_logging()
• core.tool_catalog module
  • schema_hash()
  • build_catalog_payload()
  • openai_tool_dict()
  • publish_catalog()
  • load_catalog()
• core.tool_session module
  • write_session()
  • read_session()
• core.tools_consumer module
  • ToolExecConsumer
    • ToolExecConsumer.start()
    • ToolExecConsumer.stop()
• core.trace module
  • generate_trace_id()
  • create_trace()
  • TraceWatchdog
    • TraceWatchdog.SWEEP_INTERVAL
    • TraceWatchdog.ORPHAN_THRESHOLD
    • TraceWatchdog.sweep()