base_event_bus.py¶

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

Commit: 615f1354a103

Language: python

Scope: dazzle_back

Purpose¶

Base Event Bus with shared consumer loop infrastructure.

Provides a BaseEventBus that implements the common consumer loop, subscription management, DLQ replay, and stop/unsubscribe patterns shared across the PostgreSQL, Redis, and SQLite event bus implementations.

Subclasses must implement: - All ...

Key Exports¶

ActiveSubscription
BaseEventBus
start_consumer_loop
stop_consumer_loop
unsubscribe
replay_dlq_event

Dependencies¶

Imports¶

__future__.annotations
asyncio
logging
dataclasses.dataclass
dataclasses.field
datetime.UTC
datetime.datetime
typing.Any
dazzle_back.events.bus.ConsumerNotFoundError
dazzle_back.events.bus.EventBus
dazzle_back.events.bus.EventHandler
dazzle_back.events.envelope.EventEnvelope

Event Interactions¶

None detected.

Invariants and Assumptions¶

No invariants documented.

Tests¶

tests/unit/test_events.py
tests/unit/test_events_api.py

Notes¶

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