Wheelodex » Projects » messageflux

messageflux

View on PyPI — Reverse Dependencies (1)

0.5.7 messageflux-0.5.7-py3-none-any.whl

Wheel Details

Project: messageflux
Version: 0.5.7
Filename: messageflux-0.5.7-py3-none-any.whl
Download: [link]
Size: 98718
MD5: c681c653bff5b8fda1c8f96b2519f128
SHA256: d97ff8f2603428d3b19abcf4c20f17d288bddc5d333529ed49bc9d8ed1f47c89
Uploaded: 2023-12-01 06:20:33 +0000

dist-info

METADATA · WHEEL · RECORD · top_level.txt

METADATA

Metadata-Version: 2.1
Name: messageflux
Version: 0.5.7
Author-Email: Aviv Salem <avivsalem[at]gmail.com>
Maintainer-Email: Aviv Salem <avivsalem[at]gmail.com>, Nir Schulman <narsssx[at]gmail.com>, Rafael Zilberman <Zilberman.rafi[at]gmail.com>
Project-Url: Homepage, https://github.com/Avivsalem/MessageFlux/
Project-Url: Documentation, https://messageflux.readthedocs.io/
License: MIT
Classifier: Programming Language :: Python
Classifier: Programming Language :: Python :: 3.7
Classifier: Programming Language :: Python :: 3.8
Classifier: Programming Language :: Python :: 3.9
Classifier: Programming Language :: Python :: 3.10
Classifier: Programming Language :: Python :: 3.11
Classifier: License :: OSI Approved :: MIT License
Platform: win32
Platform: linux
Requires-Python: <3.12,>=3.7
Requires-Dist: boto3-stubs[s3] (<2,>=1.25); extra == "all"
Requires-Dist: boto3-stubs[sqs] (<2,>=1.25); extra == "all"
Requires-Dist: boto3 (<2,>=1.25); extra == "all"
Requires-Dist: flake8; extra == "all"
Requires-Dist: lxml; extra == "all"
Requires-Dist: mock; extra == "all"
Requires-Dist: moto; extra == "all"
Requires-Dist: mypy; extra == "all"
Requires-Dist: pika (<2.0,>=1.0); extra == "all"
Requires-Dist: pytest; extra == "all"
Requires-Dist: pytest-cov; extra == "all"
Requires-Dist: tox; extra == "all"
Requires-Dist: types-pika; extra == "all"
Requires-Dist: pytest; extra == "dev"
Requires-Dist: pytest-cov; extra == "dev"
Requires-Dist: mock; extra == "dev"
Requires-Dist: moto; extra == "dev"
Requires-Dist: mypy; extra == "dev"
Requires-Dist: lxml; extra == "dev"
Requires-Dist: flake8; extra == "dev"
Requires-Dist: tox; extra == "dev"
Requires-Dist: boto3 (<2,>=1.25); extra == "objectstorage"
Requires-Dist: boto3 (<2,>=1.25); extra == "objectstorage-mypy"
Requires-Dist: boto3-stubs[s3] (<2,>=1.25); extra == "objectstorage-mypy"
Requires-Dist: pika (<2.0,>=1.0); extra == "rabbitmq"
Requires-Dist: pika (<2.0,>=1.0); extra == "rabbitmq-mypy"
Requires-Dist: types-pika; extra == "rabbitmq-mypy"
Requires-Dist: boto3 (<2,>=1.25); extra == "sqs"
Requires-Dist: boto3 (<2,>=1.25); extra == "sqs-mypy"
Requires-Dist: boto3-stubs[sqs] (<2,>=1.25); extra == "sqs-mypy"
Provides-Extra: all
Provides-Extra: dev
Provides-Extra: objectstorage
Provides-Extra: objectstorage_mypy
Provides-Extra: rabbitmq
Provides-Extra: rabbitmq_mypy
Provides-Extra: sqs
Provides-Extra: sqs_mypy
Description-Content-Type: text/markdown
License-File: LICENSE
[Description omitted; length: 4399 characters]

WHEEL

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

RECORD

Path Digest Size
messageflux/__init__.py sha256=xm0pSoA0BDSQxaSpdfNVV_zFgrsI9cMt-hauzNUKGH4 466
messageflux/base_service.py sha256=tzmFHObaPweALElRWrWPHS_owtgk6pvek0Tme6plRDI 5653
messageflux/message_handling_service.py sha256=VolDCQrrEA8cLfBPad8DldAXMzOpQQ_rX_SK6ZdBoQg 8993
messageflux/metadata_headers.py sha256=mLole_cA0oxNH5nXFRx6fszNHThTBM_QdddamJXsAEI 133
messageflux/pipeline_service.py sha256=hxNgoSW_P8OBASuZ-mwJd60pr4hvw-oga020l73ypSE 5752
messageflux/py.typed sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
messageflux/server_loop_service.py sha256=Mu6qN6qS65fNmPWmY1EQuIwyfKkKSCxAklI2BLuwgg8 3398
messageflux/iodevices/__init__.py sha256=MLTH1seNEV06H88VoI9wHUIUxcvRItkTTNZOGfS_gtk 107
messageflux/iodevices/base/__init__.py sha256=7Zfkm-3Sa38_r5kWKzaHGgIlP2FNYDHxFWVqBMoYRgA 668
messageflux/iodevices/base/common.py sha256=QkkwR9ESLCO2HQ742Uqq8AyU4Q3xyEVeLO_h87O8AkE 3184
messageflux/iodevices/base/input_devices.py sha256=CtDVLUBaMabvMNasG0LhvRmxtObF0oSkTannqdKmm5w 12170
messageflux/iodevices/base/input_transaction.py sha256=B3pWsu0qcANifFHBj8maqb2UV3waZ3H6lPjilEiWIgA 6963
messageflux/iodevices/base/output_devices.py sha256=VA53YNjNsYbzwJLYF7ZtwmNsCn2GNblThyyvNbz7lVs 4167
messageflux/iodevices/collection_device_wrapper/__init__.py sha256=Y5cTV_Ys663Xi7N-BP5OK37MPJZmJIZik5vVt9CsW6w 134
messageflux/iodevices/collection_device_wrapper/collection_input_device.py sha256=7fuZsUOyqbqX9qIyUzc577GKkVi-yTKm38dK9PQjcbc 6658
messageflux/iodevices/collection_device_wrapper/collection_output_device.py sha256=LTUBq7QP9LXaukfHonqpzCk-Oqlf2CCbFQ1UtwT4wDs 4895
messageflux/iodevices/failover_output_device_wrapper/__init__.py sha256=fnczXYyeqRHc5HVxDt2WZbMeRypyGjbsXJvMZjksvCQ 64
messageflux/iodevices/failover_output_device_wrapper/failover_output_device.py sha256=3m080Gi0LdmcZ7IA5xGn3jmLup302jbPQUZbNdEf6PM 6795
messageflux/iodevices/file_system/__init__.py sha256=D7Yh4cCh6wrrkpUUJuWbZf5vNF2xx4JoKiL4rpHCeQg 531
messageflux/iodevices/file_system/file_system_device_manager_base.py sha256=gm3ye1AONYKPA8M6Dx37EgC1SsAVdsIJ5EDE3Lne0NY 3236
messageflux/iodevices/file_system/file_system_input_device.py sha256=y6HM5ytZ8Kfi7tH4MOpI_UTTt6CMNoqYfBBI_cMSJdM 24756
messageflux/iodevices/file_system/file_system_output_device.py sha256=qsuq9Z43_vNDA2T8eREfBxoBjj3VcqWzSVVNUrl3Maw 6616
messageflux/iodevices/file_system/file_system_serializer.py sha256=FXnXV8HGF_9WXVmeUK_nfc3iXfPeQG-rYm5CO-bxZb8 4244
messageflux/iodevices/in_memory_device/__init__.py sha256=W6O4USJSL3X6Hx_8eCcWVnm0CGvaR_L5K3OTRux2BGw 86
messageflux/iodevices/in_memory_device/in_memory_device_manager.py sha256=ikpKsNp_H4pX5KO64tzQ8Jjn40DQHTWw_SuxgxM3ns4 5856
messageflux/iodevices/message_store_device_wrapper/__init__.py sha256=yuY4j1Vc_m7sspz_xGZ83QWO2nMkLNYuXcLrZdk_S2Y 269
messageflux/iodevices/message_store_device_wrapper/file_system_message_store.py sha256=9CXLUPCe2lwETMvcrC8rIHsfeWmhUhF9w5uWfdpC7xs 4256
messageflux/iodevices/message_store_device_wrapper/message_store_base.py sha256=AY7SiwcJrYeI02qGKSX1zZISSEeRf1V09zFXaal6-GQ 2925
messageflux/iodevices/message_store_device_wrapper/message_store_input_device.py sha256=zF8gxDgiunfe-oreHeUCi7Yykz7odRHaL8etZEWeBb8 5929
messageflux/iodevices/message_store_device_wrapper/message_store_output_device.py sha256=UWjTGl5zpC7hXlJSaZgmN71Hw4tnjwy0sWLbRznb6o8 4974
messageflux/iodevices/message_store_device_wrapper/message_store_transformer_base.py sha256=w32btXHcTK2Q5tSzt_dQqjQzsjhc2hS8Ie5BXwUyrwA 2060
messageflux/iodevices/objectstorage/__init__.py sha256=3bcM815Ppk4VYrFlxWZ3npAc9BTSG3weQ9Nz1iUlF58 178
messageflux/iodevices/objectstorage/s3_message_store.py sha256=_gml_eF22xyo-bmQy5Zekoud5_l3gVWwSb-Rr714jTI 11623
messageflux/iodevices/objectstorage/s3api/__init__.py sha256=V2VgHqDJ3z20kleT3qcBmUoFA481n1YClfvZVzi0ohQ 121
messageflux/iodevices/objectstorage/s3api/s3bucket.py sha256=cq6A0lXl3dEe5z4_UkOFdgC8x9CT1SD9XhIDPRp2XcI 14507
messageflux/iodevices/objectstorage/s3api/s3client.py sha256=mjnrzcQNA_cQLHAIOQF0IkG_Xu3ZVXUwEnC4WK_YMJA 1995
messageflux/iodevices/rabbitmq/__init__.py sha256=FvnxhYWKcKZzj-W-YKY6a1F7NN3MQ_ory59NV-xZZtM 361
messageflux/iodevices/rabbitmq/fs_poison_counter.py sha256=02pt31V15ze4c7WApYz_1VL3C7u6AjoxshS6f-YIRZg 4800
messageflux/iodevices/rabbitmq/rabbitmq_device_manager_base.py sha256=pOGgshcP5qQ1FUsqJv1jhLslqOKAIzt5I6FcY99ZkA4 14097
messageflux/iodevices/rabbitmq/rabbitmq_input_device.py sha256=D6H1-u0iFHE09Yj1AN6i9yjvVt1bQoGpbexvET8RgPs 18582
messageflux/iodevices/rabbitmq/rabbitmq_output_device.py sha256=V61-iQs7arZHPjus6lW-KdmDgy1XluWxL2eAheu1VS4 15551
messageflux/iodevices/rabbitmq/rabbitmq_poison_counting_input_device.py sha256=KO6hNavtUUYU7dyAKqkZd-htPLenuZj8FNl-xso4W2U 13023
messageflux/iodevices/round_robin_device_wrapper/__init__.py sha256=MBLhqnb-Apw_kxeENGHeIzjSM75T_4-YDS5s3XwgSPI 102
messageflux/iodevices/round_robin_device_wrapper/roundrobin_io_device_manager.py sha256=d3yT4_BpRfttqjeuQz9sAyIUNLJh-fkvwPaAc77glZ4 1543
messageflux/iodevices/short_circuit_device_wrapper/__init__.py sha256=qU-MQCXMyHaaxXxhFR6e7aADSK-PcBFZebC8fs45l7c 186
messageflux/iodevices/short_circuit_device_wrapper/common.py sha256=wWNxVGHRFjSHPO6geBqutTJtX-bDSJKNbSQA3WnQ_pk 2250
messageflux/iodevices/short_circuit_device_wrapper/short_circuit_input_device.py sha256=3mW4ib-E4Inq2wdGDFexWwK902Z3BPluwMp7KUeJcAE 3293
messageflux/iodevices/short_circuit_device_wrapper/short_circuit_output_device.py sha256=xMNsCspfTt_p7XJYHR4I4lsVAnEX7eTSQwCrpiMLuMg 2713
messageflux/iodevices/sqs/__init__.py sha256=jHxbARzKcXczd4ETHNPoFKneL3HwuNqM7Y3WjtjJIHE 106
messageflux/iodevices/sqs/message_attributes.py sha256=4DYD6a10HyBVAKfeX1YXw9fganlU3GD1uCFqRF9OPm4 1710
messageflux/iodevices/sqs/sqs_input_device.py sha256=N58WYKUuSeZCHJUy4uwm9rILAiiwmZndij0ZjM505cA 6520
messageflux/iodevices/sqs/sqs_manager_base.py sha256=tu2J2qE_N-5z1HjQAMcI7ob8puaO4dnxwD8i4wcaYlc 1503
messageflux/iodevices/sqs/sqs_output_device.py sha256=qORwmyizGm2wgefwXlx_fpfAVyWZ_HHVuZTCrjiREqs 3121
messageflux/iodevices/transformer_device_wrapper/__init__.py sha256=Mszo03qs_c4CGSTGgRzfR_BNzFF81f-aUfT2j0UKjg4 229
messageflux/iodevices/transformer_device_wrapper/transformer_input_device.py sha256=zZoEiWWOwg-kfvAGUdnRzbCqI6HKI6kJ7_Fdk9RXcLI 3960
messageflux/iodevices/transformer_device_wrapper/transformer_output_device.py sha256=ibyxcxdyLilZV5uDczBTSpdrnzPJOz8meBqBHLpPPuU 3566
messageflux/iodevices/transformer_device_wrapper/zlib_transformer.py sha256=PRl7txJD7xml0xHKIhC0VoFlPVyfsw4_1LPz3H36MAY 2179
messageflux/logging/LogType.py sha256=7ee8-39nokge6huW3CW6d8ol0zmqJpggE2w-yOOhv5Y 225
messageflux/logging/__init__.py sha256=fIV3qIoyEUz9CGjHXiQz4wais_zIFd6dPCvlp30X6wk 132
messageflux/logging/bulk_rotating_device_handler.py sha256=i_QrBN_m1b6YHUFpJJjF5yrvZ1ky8k7UxvP1h2GIM6Y 4273
messageflux/logging/bulk_rotating_file_handler.py sha256=c5ig47Vvxffukp-cDaRsIxiVnbdng8DdtjmpUvv7T4I 2027
messageflux/logging/bulk_rotating_handler_base.py sha256=SButotnGjaqmBIfCOcncXs7ZnwvAHNqC3HM7E_glCUw 8010
messageflux/logging/utils.py sha256=4kxhwNIre9gmLmSuUtPWiNS4mBU0PYSlkOucB2UMmEc 251
messageflux/multiprocessing/__init__.py sha256=nLl21tMZ83cDQQemm9p-Ucc6EN0r-mXhe62divPVKEE 168
messageflux/multiprocessing/multiprocessrunner.py sha256=3xbfJKG_d-5z1tzQwmaJrLWrrjUCF6IRgQwRa7FgxVA 6635
messageflux/multiprocessing/singleprocesshandler.py sha256=it3HHTf6UINLF2kEg43bSp1DHDNXUGXKu-wisTD0kZU 6989
messageflux/service_addons/__init__.py sha256=duRggxanYrHrk3Ek4wzep_BYGYfTt4JIbz66_UihoRI 121
messageflux/service_addons/loop_health_addon.py sha256=7xxdASYhOf2evByGUDV3E5Vo-WRK3ciy_wXDZyrHA0c 5246
messageflux/service_addons/webserver_liveness_addon.py sha256=Abuo9lWML5HN5Ee5lw7JUPKdM5sMrzNA6K-dzOvLvKk 3505
messageflux/utils/__init__.py sha256=FWm1QEeLBjHD3LItmmCO4IuHNYA-qqc3md3wyfWqlLM 7159
messageflux/utils/context.py sha256=D994guoU5S9pzCEupD76fwJWl1gqw4NrXUrT1dkELWk 4125
messageflux/utils/filesystem.py sha256=MzHdNoe9QPrv_rAM0VjUd8I1rsQIVpgS4bWiu5eWyf0 2485
messageflux-0.5.7.dist-info/LICENSE sha256=0d4djGMkmlyjyyJuw8ulrBJKagqds9tY8iVYLJrLkys 1066
messageflux-0.5.7.dist-info/METADATA sha256=0fF36iZ4lZPIhXgXfBJGPjq85ei58CP4Pqvs0cRlxMs 6837
messageflux-0.5.7.dist-info/WHEEL sha256=oiQVh_5PnQM0E3gPdiz09WCNmwiHDMaGer_elqB3coM 92
messageflux-0.5.7.dist-info/top_level.txt sha256=ZeQUMlLm7KxhPqJpAaQJxe50hIx3y5uEoy9gMQeBL9Q 12
messageflux-0.5.7.dist-info/RECORD — —

top_level.txt

messageflux