Skip to content

src/dazzle_back/events/bus.py

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

Commit: 615f1354a103

Language: python

Scope: dazzle_back

Purpose

EventBus Abstract Interface for Dazzle Event-First Architecture.

This module defines the abstract interface that all event bus implementations must follow. The interface is Kafka-shaped, supporting: - Topic-based publish/subscribe - Consumer groups with offset tracking - Acknowledgment/rejection fo...

Key Exports

  • SubscriptionInfo
  • ConsumerStatus
  • NackReason
  • EventBus
  • EventBusError
  • TopicNotFoundError
  • ConsumerNotFoundError
  • EventNotFoundError
  • PublishError
  • SubscriptionError
  • transient_error
  • permanent_error
  • schema_error
  • handler_error
  • publish
  • subscribe
  • unsubscribe
  • ack
  • nack
  • replay

Dependencies

Imports

  • __future__.annotations
  • abc.ABC
  • abc.abstractmethod
  • collections.abc.AsyncIterator
  • collections.abc.Awaitable
  • collections.abc.Callable
  • dataclasses.dataclass
  • dataclasses.field
  • datetime.datetime
  • typing.Any
  • uuid.UUID
  • dazzle_back.events.envelope.EventEnvelope

Event Interactions

None detected.

Invariants and Assumptions

No invariants documented.

Tests

  • tests/unit/test_bus_conformance.py
  • tests/unit/test_event_bus_wiring.py
  • tests/unit/test_eventbus_adapter.py
  • tests/unit/test_event_bus_hless.py
  • tests/unit/test_null_event_bus.py

Notes

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