Skip to content

src/dazzle_back/runtime/event_bus.py

Generated: 2026-03-30T04:38:47.153694+00:00

Commit: 615f1354a103

Language: python

Scope: dazzle_back

Purpose

Event bus for DNR entity change events.

Provides decoupled event publishing from repositories to WebSocket broadcasts.

Key Exports

  • EntityEventType
  • LLMEventType
  • EntityEvent
  • EntityEventBus
  • RealtimeRepositoryMixin
  • create_event_bus
  • channel
  • record_channel
  • set_websocket_manager
  • add_handler
  • add_sync_handler
  • remove_handler
  • remove_sync_handler
  • enable
  • disable
  • is_enabled
  • emit
  • emit_created
  • emit_updated
  • emit_deleted

Dependencies

Imports

  • __future__.annotations
  • logging
  • collections.abc.Awaitable
  • collections.abc.Callable
  • dataclasses.dataclass
  • dataclasses.field
  • enum.StrEnum
  • typing.TYPE_CHECKING
  • typing.Any
  • uuid.UUID
  • dazzle_back.runtime.websocket_manager.WebSocketManager
  • dazzle_back.runtime.websocket_manager.RealtimeMessage

Event Interactions

Emits: EntityEvent, entity.created, entity.deleted, entity.updated

Consumes: EntityEvent

Invariants and Assumptions

  • entity_name: str # Must be set by the repository (as class attribute)

Tests

  • tests/unit/test_event_bus_wiring.py
  • tests/unit/test_event_bus_hless.py
  • tests/unit/test_null_event_bus.py
  • tests/integration/test_runtime_e2e.py
  • tests/integration/test_runtime_pipeline.py

Notes

This page was automatically generated by tools/gen_reference_docs.py.