redis_bus.py¶

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

Commit: 615f1354a103

Language: python

Scope: dazzle_back

Purpose¶

Redis Streams Event Bus for Dazzle (Tier 2).

Provides a high-throughput event bus using Redis Streams with: - Consumer groups for competing consumers - XREADGROUP for efficient blocking reads - XACK for acknowledgment - Automatic pending message recovery

Ideal for Heroku deployments needing higher...

Key Exports¶

RedisConfig
ActiveSubscription
RedisBus
connect
close
publish
subscribe
ack
nack
replay
get_consumer_status
list_topics
list_consumer_groups
get_topic_info
start_consumer_loop
get_dlq_events
get_dlq_count
clear_dlq
get_str
get_uuid

Dependencies¶

Imports¶

__future__.annotations
asyncio
json
logging
collections.abc.AsyncIterator
dataclasses.dataclass
dataclasses.field
datetime.UTC
datetime.datetime
typing.TYPE_CHECKING
typing.Any
uuid.UUID
uuid.uuid4
dazzle_back.events.base_event_bus.BaseEventBus
dazzle_back.events.bus.ConsumerNotFoundError
dazzle_back.events.bus.ConsumerStatus
dazzle_back.events.bus.EventHandler
dazzle_back.events.bus.NackReason
dazzle_back.events.bus.SubscriptionInfo
dazzle_back.events.envelope.EventEnvelope

Event Interactions¶

Emits: app.Order

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.