LICENSE
README.md
pyproject.toml
src/cqrs/__init__.py
src/cqrs/_dataclass_utils.py
src/cqrs/circuit_breaker.py
src/cqrs/generic_utils.py
src/cqrs/sqlalchemy_types.py
src/cqrs/types.py
src/cqrs/adapters/__init__.py
src/cqrs/adapters/amqp.py
src/cqrs/adapters/circuit_breaker.py
src/cqrs/adapters/kafka.py
src/cqrs/adapters/protocol.py
src/cqrs/bootstrap/__init__.py
src/cqrs/bootstrap/events.py
src/cqrs/bootstrap/requests.py
src/cqrs/bootstrap/saga.py
src/cqrs/compressors/__init__.py
src/cqrs/compressors/protocol.py
src/cqrs/compressors/zlib.py
src/cqrs/container/__init__.py
src/cqrs/container/dependency_injector.py
src/cqrs/container/di.py
src/cqrs/container/dishka.py
src/cqrs/container/protocol.py
src/cqrs/container/scope.py
src/cqrs/deserializers/__init__.py
src/cqrs/deserializers/exceptions.py
src/cqrs/deserializers/json.py
src/cqrs/deserializers/protobuf.py
src/cqrs/dispatcher/__init__.py
src/cqrs/dispatcher/event.py
src/cqrs/dispatcher/exceptions.py
src/cqrs/dispatcher/models.py
src/cqrs/dispatcher/request.py
src/cqrs/dispatcher/saga.py
src/cqrs/dispatcher/streaming.py
src/cqrs/events/__init__.py
src/cqrs/events/event_emitter.py
src/cqrs/events/event_processor.py
src/cqrs/events/fallback.py
src/cqrs/handlers/__init__.py
src/cqrs/handlers/cor.py
src/cqrs/handlers/event.py
src/cqrs/handlers/request.py
src/cqrs/handlers/saga.py
src/cqrs/mapping/__init__.py
src/cqrs/mapping/events.py
src/cqrs/mapping/outbox.py
src/cqrs/mapping/requests.py
src/cqrs/mediators/__init__.py
src/cqrs/mediators/_common.py
src/cqrs/mediators/event.py
src/cqrs/mediators/request.py
src/cqrs/mediators/saga.py
src/cqrs/mediators/streaming.py
src/cqrs/mermaid/__init__.py
src/cqrs/mermaid/cor.py
src/cqrs/mermaid/saga.py
src/cqrs/message_brokers/__init__.py
src/cqrs/message_brokers/amqp.py
src/cqrs/message_brokers/devnull.py
src/cqrs/message_brokers/kafka.py
src/cqrs/message_brokers/producer.py
src/cqrs/message_brokers/protocol.py
src/cqrs/middlewares/__init__.py
src/cqrs/middlewares/base.py
src/cqrs/middlewares/logging.py
src/cqrs/models/__init__.py
src/cqrs/models/event.py
src/cqrs/models/pydantic.py
src/cqrs/models/request.py
src/cqrs/models/response.py
src/cqrs/outbox/__init__.py
src/cqrs/outbox/mock.py
src/cqrs/outbox/repository.py
src/cqrs/outbox/sqlalchemy.py
src/cqrs/requests/__init__.py
src/cqrs/requests/fallback.py
src/cqrs/saga/__init__.py
src/cqrs/saga/circuit_breaker.py
src/cqrs/saga/compensation.py
src/cqrs/saga/execution.py
src/cqrs/saga/fallback.py
src/cqrs/saga/models.py
src/cqrs/saga/recovery.py
src/cqrs/saga/saga.py
src/cqrs/saga/validation.py
src/cqrs/saga/storage/__init__.py
src/cqrs/saga/storage/enums.py
src/cqrs/saga/storage/memory.py
src/cqrs/saga/storage/models.py
src/cqrs/saga/storage/protocol.py
src/cqrs/saga/storage/sqlalchemy.py
src/cqrs/serializers/__init__.py
src/cqrs/serializers/default.py
src/cqrs/serializers/json.py
src/cqrs/serializers/protobuf.py
src/cqrs/serializers/protocol.py
src/python_cqrs.egg-info/PKG-INFO
src/python_cqrs.egg-info/SOURCES.txt
src/python_cqrs.egg-info/dependency_links.txt
src/python_cqrs.egg-info/requires.txt
src/python_cqrs.egg-info/top_level.txt