src/dazzle_back/channels/adapters/stream.py

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

Commit: 615f1354a103

Language: python

Scope: dazzle_back

Purpose

Stream channel adapters for DAZZLE messaging.

Provides adapters for: - Redis Streams (production) - Kafka (production) - In-memory stream (development/testing fallback)

Key Exports

• RedisStreamAdapter
• KafkaAdapter
• InMemoryStreamAdapter
• provider_name
• initialize
• shutdown
• send
• subscribe
• unsubscribe
• health_check
• provider_name
• initialize
• shutdown
• send
• subscribe
• unsubscribe
• health_check
• provider_name
• initialize
• shutdown

Dependencies

Imports

• __future__.annotations
• asyncio
• json
• logging
• time
• collections.deque
• collections.abc.Callable
• collections.abc.Coroutine
• typing.TYPE_CHECKING
• typing.Any
• typing.ClassVar
• base.SendResult
• base.SendStatus
• base.StreamAdapter
• detection.DetectionResult
• outbox.OutboxMessage
• redis.asyncio
• aiokafka.AIOKafkaProducer
• aiokafka.AIOKafkaConsumer

Event Interactions

Emits: OutboxMessage

Invariants and Assumptions

No invariants documented.

Tests

• tests/unit/test_stream_adapters.py
• tests/parser_corpus/test_streamspec_corpus.py
• tests/unit/test_adapters.py

Notes

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