.flake8
.gitignore
.pre-commit-config.yaml
Dockerfile
LICENSE
README.md
RELEASING.md
benchmark-requirements.txt
benchmark.py
docker-compose.yaml
mypy.ini
pyproject.toml
pytest.ini
requirements.txt
setup.cfg
setup.py
test-requirements.txt
tests.py
tox.ini
.github/workflows/publish.yml
.github/workflows/test.yml
async_kinesis.egg-info/PKG-INFO
async_kinesis.egg-info/SOURCES.txt
async_kinesis.egg-info/dependency_links.txt
async_kinesis.egg-info/requires.txt
async_kinesis.egg-info/top_level.txt
docs/DESIGN.md
docs/YETANOTHER.md
docs/common-patterns.md
docs/dynamodb-checkpointing.md
docs/getting-started.md
docs/metrics.md
docs/troubleshooting.md
kinesis/__init__.py
kinesis/aggregators.py
kinesis/base.py
kinesis/checkpointers.py
kinesis/consumer.py
kinesis/dynamodb.py
kinesis/exceptions.py
kinesis/metrics.py
kinesis/processors.py
kinesis/producer.py
kinesis/prometheus.py
kinesis/serializers.py
kinesis/timeout_compat.py
kinesis/utils.py
scripts/release.py
tests/__init__.py
tests/conftest.py
tests/test_checkpointers.py
tests/test_consumer.py
tests/test_dynamodb_checkpointer.py
tests/test_integration.py
tests/test_metrics_unit.py
tests/test_processors.py
tests/test_producer.py
tests/resharding/README.md
tests/resharding/resharding_test.py
tests/resharding/test_resharding_detection.py
tests/resharding/test_resharding_in_progress.py
tests/resharding/test_resharding_integration.py
tests/resharding/test_resharding_simple.py
tests/resharding/test_start_during_resharding.py