LICENSE
MANIFEST.in
README.md
pyproject.toml
setup.py
../mmapq/src/appender_id_pool.c
../mmapq/src/appender_meta.c
../mmapq/src/batch_payload_iterator.c
../mmapq/src/batch_queue_latency_probe.c
../mmapq/src/batch_queue_transfer.c
../mmapq/src/file_initialiser.c
../mmapq/src/file_mapper_rolled.c
../mmapq/src/file_mapper_single_ro.c
../mmapq/src/file_mapper_single_rw.c
../mmapq/src/fixed_size_region.c
../mmapq/src/header_reader.c
../mmapq/src/indexed_appender.c
../mmapq/src/indexed_archiver.c
../mmapq/src/indexed_batch_appender.c
../mmapq/src/indexed_batch_archiver.c
../mmapq/src/indexed_batch_poller.c
../mmapq/src/indexed_batch_queue.c
../mmapq/src/indexed_batch_reader.c
../mmapq/src/indexed_poller.c
../mmapq/src/indexed_queue.c
../mmapq/src/indexed_reader.c
../mmapq/src/mmapq_strerror.c
../mmapq/src/payload_iterator.c
../mmapq/src/payload_walk.c
../mmapq/src/queue_files.c
../mmapq/src/queue_latency_probe.c
../mmapq/src/queue_meta.c
../mmapq/src/queue_region_accessor.c
../mmapq/src/queue_transfer.c
../mmapq/src/region_async.c
../mmapq/src/region_ring.c
../mmapq/src/region_ring_accessor.c
../mmapq/src/region_sync.c
../mmapq/src/runtime.c
../mmapq/src/uncommitted_payload_iterator.c
c/include/batch_payload_iterator.h
c/include/batch_queue_transfer.h
c/include/indexed_appender.h
c/include/indexed_archiver.h
c/include/indexed_batch_appender.h
c/include/indexed_batch_archiver.h
c/include/indexed_batch_poller.h
c/include/indexed_batch_queue.h
c/include/indexed_batch_reader.h
c/include/indexed_poller.h
c/include/indexed_queue.h
c/include/indexed_reader.h
c/include/mmap_platform.h
c/include/mmapq.h
c/include/poller.h
c/include/queue_transfer.h
c/include/runtime.h
c/src/appender_id_pool.c
c/src/appender_meta.c
c/src/batch_payload_iterator.c
c/src/batch_queue_latency_probe.c
c/src/batch_queue_transfer.c
c/src/file_initialiser.c
c/src/file_mapper_rolled.c
c/src/file_mapper_single_ro.c
c/src/file_mapper_single_rw.c
c/src/fixed_size_region.c
c/src/header_reader.c
c/src/indexed_appender.c
c/src/indexed_archiver.c
c/src/indexed_batch_appender.c
c/src/indexed_batch_archiver.c
c/src/indexed_batch_poller.c
c/src/indexed_batch_queue.c
c/src/indexed_batch_reader.c
c/src/indexed_poller.c
c/src/indexed_queue.c
c/src/indexed_reader.c
c/src/mmapq_strerror.c
c/src/payload_iterator.c
c/src/payload_walk.c
c/src/queue_files.c
c/src/queue_latency_probe.c
c/src/queue_meta.c
c/src/queue_region_accessor.c
c/src/queue_transfer.c
c/src/region_async.c
c/src/region_ring.c
c/src/region_ring_accessor.c
c/src/region_sync.c
c/src/runtime.c
c/src/uncommitted_payload_iterator.c
c/src/internal/appender_cache.h
c/src/internal/appender_id_pool.h
c/src/internal/appender_meta.h
c/src/internal/batch_payload_iterator_internal.h
c/src/internal/batch_queue_latency_probe.h
c/src/internal/export_meta.h
c/src/internal/file_initialiser.h
c/src/internal/file_mapper.h
c/src/internal/fixed_size_region.h
c/src/internal/header_codec.h
c/src/internal/header_reader.h
c/src/internal/mmap_assert.h
c/src/internal/mmap_stats.h
c/src/internal/payload_iterator.h
c/src/internal/payload_walk.h
c/src/internal/platform_internal.h
c/src/internal/queue_files.h
c/src/internal/queue_latency_probe.h
c/src/internal/queue_meta.h
c/src/internal/queue_region_accessor.h
c/src/internal/region.h
c/src/internal/region_accessor.h
c/src/internal/region_ring.h
c/src/internal/region_ring_accessor.h
c/src/internal/uncommitted_payload_iterator.h
src/mmapq/__init__.py
src/mmapq/_cdata.py
src/mmapq/_errors.py
src/mmapq/archiver.py
src/mmapq/batch_appender.py
src/mmapq/batch_poller.py
src/mmapq/batch_queue.py
src/mmapq/reader.py
src/mmapq/runtime.py
src/mmapq/single_appender.py
src/mmapq/single_poller.py
src/mmapq/single_queue.py
src/mmapq/transfer.py
src/mmapq/types.py
src/mmapq.egg-info/PKG-INFO
src/mmapq.egg-info/SOURCES.txt
src/mmapq.egg-info/dependency_links.txt
src/mmapq.egg-info/requires.txt
src/mmapq.egg-info/top_level.txt
tests/test_poller_lifecycle.py
tests/test_queue.py