AUTHORS.rst
LICENSE.txt
MANIFEST.in
README.rst
release-history.rst
requirements-automation.txt
requirements-aws.txt
requirements-dev.txt
requirements-doc.txt
requirements-furo-sphinx-search.txt
requirements-test.txt
requirements.txt
setup.py
tests/test_api.py
tests/test_buffers_file_buffer.py
tests/test_checkpoint.py
tests/test_checkpoints_dynamodb_s3.py
tests/test_checkpoints_simple.py
tests/test_consumer.py
tests/test_producer.py
tests/test_produces_simple.py
tests/test_records_dataclass.py
tests/test_utils.py
unistream/__init__.py
unistream/_version.py
unistream/abstraction.py
unistream/api.py
unistream/buffer.py
unistream/checkpoint.py
unistream/consumer.py
unistream/exc.py
unistream/logger.py
unistream/paths.py
unistream/producer.py
unistream/record.py
unistream/utils.py
unistream.egg-info/PKG-INFO
unistream.egg-info/SOURCES.txt
unistream.egg-info/dependency_links.txt
unistream.egg-info/requires.txt
unistream.egg-info/top_level.txt
unistream/buffers/__init__.py
unistream/buffers/file_buffer.py
unistream/checkpoints/__init__.py
unistream/checkpoints/dynamodb_s3.py
unistream/checkpoints/simple.py
unistream/consumers/__init__.py
unistream/consumers/aws_kinesis.py
unistream/consumers/simple.py
unistream/docs/__init__.py
unistream/producers/__init__.py
unistream/producers/aws_cloudwatch_logs.py
unistream/producers/aws_kinesis.py
unistream/producers/simple.py
unistream/records/__init__.py
unistream/records/aws_kinesis.py
unistream/records/dataclass.py
unistream/tests/__init__.py
unistream/tests/helper.py
unistream/tests/mock_aws.py
unistream/vendor/__init__.py
unistream/vendor/aws_cloudwatch_logs_insights_query.py
unistream/vendor/better_dataclass.py
unistream/vendor/better_enum.py
unistream/vendor/nested_logger.py
unistream/vendor/pytest_cov_helper.py