src/dazzle_back/channels/providers/stream.py

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

Commit: 615f1354a103

Language: python

Scope: dazzle_back

Purpose

Stream provider detectors for DAZZLE messaging.

Supports: - Redis Streams (production) - Kafka (production) - In-memory stream (fallback)

Key Exports

• RedisDetector
• KafkaDetector
• InMemoryStreamDetector
• provider_name
• channel_kind
• priority
• detect
• health_check
• provider_name
• channel_kind
• priority
• detect
• health_check
• provider_name
• channel_kind
• priority
• detect
• health_check

Dependencies

Imports

• __future__.annotations
• logging
• typing.TYPE_CHECKING
• detection.DetectionResult
• detection.ProviderDetector
• detection.ProviderStatus
• detection.check_docker_container
• detection.check_port
• detection.get_env_var
• redis.asyncio

Event Interactions

None detected.

Invariants and Assumptions

No invariants documented.

Tests

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

Notes

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