aiosafeconsumer

View on PyPIReverse Dependencies (0)

0.0.4 aiosafeconsumer-0.0.4-py3-none-any.whl

Wheel Details

Project: aiosafeconsumer
Version: 0.0.4
Filename: aiosafeconsumer-0.0.4-py3-none-any.whl
Download: [link]
Size: 20019
MD5: 87687ea424228ac7e5fcd82a7b34594b
SHA256: f5eb158d741ab443fa2adad66c4e19a0748e4beb79bd102de2a9c233b7319f68
Uploaded: 2024-10-30 15:52:09 +0000

dist-info

METADATA

Metadata-Version: 2.1
Name: aiosafeconsumer
Version: 0.0.4
Summary: Safely consume and process data.
Author-Email: Kostiantyn Korikov <lostclus[at]gmail.com>
Project-Url: Repository, http://github.com/lostclus/aiosafeconsumer
Keywords: asyncio,consumer,microservices
Classifier: Development Status :: 3 - Alpha
Classifier: Environment :: No Input/Output (Daemon)
Classifier: Framework :: AsyncIO
Classifier: Intended Audience :: Developers
Classifier: License :: OSI Approved :: BSD License
Classifier: Operating System :: OS Independent
Classifier: Programming Language :: Python
Classifier: Programming Language :: Python :: 3
Classifier: Programming Language :: Python :: 3.10
Classifier: Programming Language :: Python :: 3.11
Classifier: Programming Language :: Python :: 3.12
Classifier: Programming Language :: Python :: 3.13
Classifier: Typing :: Typed
Requires-Python: >=3.10
Requires-Dist: croniter
Requires-Dist: elasticsearch[async]; extra == "elasticsearch"
Requires-Dist: aiokafka; extra == "kafka"
Requires-Dist: redis[hiredis]; extra == "redis"
Requires-Dist: aiokafka; extra == "tests"
Requires-Dist: elasticsearch[async]; extra == "tests"
Requires-Dist: pytest; extra == "tests"
Requires-Dist: pytest-asyncio; extra == "tests"
Requires-Dist: pytest-cov; extra == "tests"
Requires-Dist: redis[hiredis]; extra == "tests"
Provides-Extra: elasticsearch
Provides-Extra: kafka
Provides-Extra: redis
Provides-Extra: tests
Description-Content-Type: text/x-rst
License-File: LICENSE
[Description omitted; length: 1867 characters]

WHEEL

Wheel-Version: 1.0
Generator: setuptools (75.3.0)
Root-Is-Purelib: true
Tag: py3-none-any

RECORD

Path Digest Size
aiosafeconsumer/__init__.py sha256=k47OymrTLBQ4AdAdxDturbsSNEejxFvaIEzrM2eMdk4 723
aiosafeconsumer/consumer.py sha256=ChIsJ-qe8El-zxVgq9_JYbI78GV0Ac9UeMiCuH8DOwk 2203
aiosafeconsumer/kafka.py sha256=isobvgtRqEtzIEd8-af9PnkWGHQpvOF5FqxLhHdwMaQ 7046
aiosafeconsumer/kafka_stubs.py sha256=SNPSpTrPbQHvomdr2geM46wPfH5U4-w5SHAaxAvzGns 603
aiosafeconsumer/logging.py sha256=xYXusYDvi0JzMS6GOHmnxZQhCzCYXI34CVYHVrRJkDE 1771
aiosafeconsumer/logging_context.py sha256=UAgdLU5hczLGor4ko7_B3RvCgP7PseQoDdiJh9W7Ce8 285
aiosafeconsumer/processor.py sha256=lfszOSzyj_1cAGd6_m-ScUazLSAzeDsRtXlVW_4gw4g 1527
aiosafeconsumer/py.typed sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
aiosafeconsumer/run.py sha256=ZMSaQ5MB05IBJNF8_f8rOCUoz4kz2B_Xa01aK0k2IPw 8739
aiosafeconsumer/source.py sha256=bOpwTlGheYcSL_aGWHCd_eVEig9_CJsOVnW0HPuHnbw 1006
aiosafeconsumer/types.py sha256=63zDmkY7PBoTCyQbJh5KpENcL8Ojq_gkd-HZ2I10D74 102
aiosafeconsumer/worker.py sha256=LclHe0pyvVIMEWwn_6xFEAtoD4Hbdt1jfjxvxh7wnpE 1082
aiosafeconsumer/workerpool.py sha256=HbZ4OaPQMUaYTfZ1Us9OuFr_kg8lWDehlv7aKjXC1P0 6674
aiosafeconsumer/datasync/__init__.py sha256=C8bqogJc1augRWnfzet_1dI_QnhUJTV73XqGZNnxE0c 311
aiosafeconsumer/datasync/base.py sha256=1zYunpjMJQiwhqzVxYVuWfvLqIDA5AEQXqx8RCfS8BY 669
aiosafeconsumer/datasync/elasticsearch.py sha256=nHDx5lyHE26VCO4Y0PP1N8Au_-N3RqbpG393nKkIaRE 7840
aiosafeconsumer/datasync/redis.py sha256=EvyNj0GhnTcJK08x8N3lQaNGwMBYKwCsIEbZuS_66lI 9436
aiosafeconsumer/datasync/types.py sha256=fU_PZZYWlhIMj7gASG5k3skaFfxjfjDRdmQIyw9eJJ4 707
aiosafeconsumer-0.0.4.dist-info/LICENSE sha256=ySJ3eEaZWnkgL-dXmwI_xoGhRHbiQdFdJendHmzFHy8 1348
aiosafeconsumer-0.0.4.dist-info/METADATA sha256=IBJWKW00J9AvBK7O5H1ajX6dsnpkQHhqf9rDWiHIEkI 3366
aiosafeconsumer-0.0.4.dist-info/WHEEL sha256=P9jw-gEje8ByB7_hXoICnHtVCrEwMQh-630tKvQWehc 91
aiosafeconsumer-0.0.4.dist-info/top_level.txt sha256=UkQW8YFMDdR437OvawWBx35KeZarj7nyyIyYab_XQZ8 16
aiosafeconsumer-0.0.4.dist-info/RECORD

top_level.txt

aiosafeconsumer