Wheelodex » Projects » flowgate

flowgate

View on PyPI — Reverse Dependencies (0)

0.0.5 flowgate-0.0.5-py2.py3-none-any.whl

Wheel Details

Project: flowgate
Version: 0.0.5
Filename: flowgate-0.0.5-py2.py3-none-any.whl
Download: [link]
Size: 21512
MD5: 168c18b82207a0e03f0de4eb274affcc
SHA256: 7b866cf06b18856f92581ed0c636c14286ed7494948094e3bca5c2cb5eb44ba6
Uploaded: 2025-03-25 17:56:27 +0000

dist-info

METADATA · WHEEL · RECORD

METADATA

Metadata-Version: 2.4
Name: flowgate
Version: 0.0.5
Summary: Flowgate is a kafka client library for building event-driven systems.
Author-Email: nf1s <ahmed.nafies[at]gmail.com>
Project-Url: Homepage, https://github.com/nf1s/flowgate
Project-Url: Issues, https://github.com/nf1s/flowgate/issues
License: MIT
Classifier: License :: OSI Approved :: MIT License
Classifier: Operating System :: OS Independent
Classifier: Programming Language :: Python :: 3
Requires-Dist: confluent-kafka (>=1.8.2)
Requires-Dist: confluent-kafka[avro] (>=1.8.2)
Requires-Dist: jsonpickle (>=0.9.6)
Requires-Dist: structlog (>=17.2.0)
Requires-Dist: cnamedtuple (>=0.1.6); extra == "cnamedtuple"
Requires-Dist: fakeredis; extra == "dev"
Requires-Dist: flake8; extra == "dev"
Requires-Dist: flake8-eradicate; extra == "dev"
Requires-Dist: flake8-isort; extra == "dev"
Requires-Dist: ipdb; extra == "dev"
Requires-Dist: isort; extra == "dev"
Requires-Dist: mongomock; extra == "dev"
Requires-Dist: mypy; extra == "dev"
Requires-Dist: pdbpp; extra == "dev"
Requires-Dist: pytest; extra == "dev"
Requires-Dist: pytest-coverage; extra == "dev"
Requires-Dist: pytest-mock; extra == "dev"
Requires-Dist: pytest-sugar; extra == "dev"
Requires-Dist: types-redis; extra == "dev"
Requires-Dist: yapf; extra == "dev"
Requires-Dist: pymongo (>=3.6.1); extra == "mongo"
Requires-Dist: hiredis (>=0.2.0); extra == "redis"
Requires-Dist: redis (>=2.10.6); extra == "redis"
Provides-Extra: cnamedtuple
Provides-Extra: dev
Provides-Extra: mongo
Provides-Extra: redis
Description-Content-Type: text/markdown
[Description omitted; length: 2036 characters]

WHEEL

Wheel-Version: 1.0
Generator: hatchling 1.27.0
Root-Is-Purelib: true
Tag: py2-none-any
Tag: py3-none-any

RECORD

Path Digest Size
flowgate/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
flowgate/command_handler.py sha256=Wwn6iDRuxLIaSVbv37refzFJmOblj2BWSHbHVGQm_Js 1391
flowgate/consumer.py sha256=W06dJIkfgc26Jna9VFQmtWSkl0jz7rv5I1EOxGuaFek 348
flowgate/event_handler.py sha256=AIJowewJ6VKdfXOnFgc4OHlzB70GLdHYyr0lAgzlhvQ 1044
flowgate/handler.py sha256=ZbV3VNiq4qduUzObzv2s3l_C0mrxzvmwDdz_6XpzBuU 530
flowgate/message.py sha256=R-WRfpHBZh2KwnQQWpHjDr5KzrZK-6ZHFtbE0TaXhS0 1411
flowgate/serializers.py sha256=ITZpnJLDf3LTt_ApGrPBnHawO1Qqzkv_MgK-DxfUHDA 687
flowgate/utils.py sha256=75cXyJS4Zo-fsOFLiuqq5RiMfLi5-g5g8s8JN4vWrMU 973
flowgate/messagebus/__init__.py sha256=XF9WXaV-OuFBrNy39EZo2EPavxhv8qgvJLDc_s6H2vY 80
flowgate/messagebus/base.py sha256=kSC51WDMHU1zAfOg3Db92qCk8TDxKirt7boBnvYfFZE 241
flowgate/messagebus/messagebus.py sha256=8AWWVKW0K5VVIaH1Y3ocyN4PUlrJoKToplB-IGqsLYk 964
flowgate/messagebus/kafka/__init__.py sha256=jM3obDrqlG6LdrdKWlqUMsapZb7_KCxiSZ-Zh3BgosE 119
flowgate/messagebus/kafka/avro.py sha256=1mWjppbyP5FgRhDw5OZ_bk9wxk6sSQwg3iIevusbiWQ 3888
flowgate/messagebus/kafka/config.py sha256=DkVwNC1u5O2xV6SJkW6ues_C3n1osPPvz2gw-ykKwN8 1621
flowgate/messagebus/kafka/offset_watchdog/__init__.py sha256=DGzgM_MIehvqFm4Cg9k2eJjgp7BtMWD1yIjG_kc7II0 1603
flowgate/messagebus/kafka/offset_watchdog/base.py sha256=AMtwxChFqpxMnfITITDjkVyxn5Y0YTh1gZpyi6c4RT8 512
flowgate/messagebus/kafka/offset_watchdog/memory.py sha256=XYKJrMUe3cNq6UwIza8FiAajOmmXBw5AHKXfG0B6JYE 609
flowgate/messagebus/kafka/offset_watchdog/null.py sha256=81IcGHrxcW2m4ZgJAQvQSRltdTbGvxQ6SgCKXA6cRmk 330
flowgate/messagebus/kafka/offset_watchdog/redis.py sha256=Bp7WovmppCcKk8-3gvtrmLQYj1f-IXqx1oF9a6lQvHQ 1921
flowgate/messagebus/testing/__init__.py sha256=wE9h_OjcznbzitbE92Vu-NeO5H11BdEdDK_-v1xP4A8 95
flowgate/messagebus/testing/kafka.py sha256=_NjZ7e3T8G9mpKEC-cgIjuYmy0K7unnfSWpJPIJWhi8 2574
flowgate/messagebus/testing/utils.py sha256=Ef9RXGMraVWSzanCXP8y8Daw03fLSlK3YVMx-eNPmas 2925
flowgate/services/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
flowgate/services/kafka/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
flowgate/services/kafka/avro/__init__.py sha256=zbfS_Qu8djj9msQ21gPUgVzvNYxEChS-z1V-QBfA5rM 1457
flowgate/services/kafka/avro/config.py sha256=00oNTPOoLgmocMXneUZIr6oWaOQCg69Niimm5Pc8Gj4 644
flowgate/services/kafka/avro/consumer.py sha256=PHD6ZacCPDpy6uLjGLgZBkB2rHQaor2FGGrR0aXnOXU 4692
flowgate/services/kafka/avro/exceptions.py sha256=V-YCf-oOuJesuUQNdilyvIHPZTGbxP8UbFH-2vvy9OM 390
flowgate/services/kafka/avro/message.py sha256=8rRhmpo5zXWOctHNCPKPYERhE5bSO0OKOWAZfRubAp8 2644
flowgate/services/kafka/avro/producer.py sha256=0PZrkOAHzbKa-4R1nEnbqAd5LhmOa8F3uMayMi5qeWk 3264
flowgate/services/kafka/avro/schema_registry.py sha256=CVwLzSrHxdVvTqtuVS3tOLHqrg9RjTwXYVNeD7mhSAY 1517
flowgate/services/kafka/avro/utils.py sha256=4_KkDN8WXd6e9FxJd7dlZ1SuXd9481Rnu-2iEEtv_e0 1797
flowgate-0.0.5.dist-info/METADATA sha256=OEGkMPf36m6h3Xx9t1DzIjKgEvLgP6q2ietf9Uhub1c 3638
flowgate-0.0.5.dist-info/WHEEL sha256=tkmg4JIqwd9H8mL30xA7crRmoStyCtGp0VWshokd1Jc 105
flowgate-0.0.5.dist-info/RECORD — —