openmsistream
View on PyPI — Reverse Dependencies (0)
1.8.0 | openmsistream-1.8.0-py3-none-any.whl |
Wheel Details
Project: | openmsistream |
Version: | 1.8.0 |
Filename: | openmsistream-1.8.0-py3-none-any.whl |
Download: | [link] |
Size: | 158920 |
MD5: | 45af60e52e224970bdf33f09e5b9bf69 |
SHA256: | 69ae7b3a9bab74f9909a47a5ea150ec9c614ba0451f907da73232851cd286473 |
Uploaded: | 2024-08-29 20:12:30 +0000 |
dist-info
METADATA · WHEEL · RECORD · top_level.txt · entry_points.txt
METADATA
WHEEL
Wheel-Version: | 1.0 |
Generator: | bdist_wheel (0.37.1) |
Root-Is-Purelib: | true |
Tag: | py3-none-any |
RECORD
Path | Digest | Size |
---|---|---|
openmsistream/__init__.py | sha256=1ik5FpgNBMU3O_VV_OQQSv5xxIt87tBuYrZ5OuvjGR4 | 2463 |
openmsistream/version.py | sha256=Oc_xF94AMAHKZkZlB5rBt1iO0TXWFalg65MP4T2qt-A | 22 |
openmsistream/data_file_io/__init__.py | sha256=Vqqg6e49ys6tjYgjzhpRwa4HAchbyVlwlUYtjFq6WwI | 641 |
openmsistream/data_file_io/config.py | sha256=6j_RjBNoMsm4VWBwyrO08w_0j-x9c8Tgz_KPvxbTEPs | 398 |
openmsistream/data_file_io/utilities.py | sha256=amp6-PWOGzxlhyMU3_d0Xz-0uxvoBRRUAfIorwhXcDA | 2380 |
openmsistream/data_file_io/actor/__init__.py | sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU | 0 |
openmsistream/data_file_io/actor/data_file_chunk_handlers.py | sha256=0QcHSW3Mb_-_ezj6R-7mNbVC0mdp3AJKE3WhPe78vN0 | 7814 |
openmsistream/data_file_io/actor/data_file_download_directory.py | sha256=VRk3-n798TnfCXznWzUzylkPcBjAYUv8QuxLo74iPFk | 10791 |
openmsistream/data_file_io/actor/data_file_stream_handler.py | sha256=aYs6AgGLk4Q9B51OIY_aKbtUaP4CCNWlt87u5K11Bew | 8424 |
openmsistream/data_file_io/actor/data_file_stream_processor.py | sha256=m0iH0gjjKjz3vavNN3c6uYoduHn-Kmx06oIW8yHcf1Q | 12779 |
openmsistream/data_file_io/actor/data_file_stream_reproducer.py | sha256=-S8mj1jA8yyJrh0hEo1xwgizGhtkoWiry8Ercm4G4pE | 18738 |
openmsistream/data_file_io/actor/data_file_upload_directory.py | sha256=pJpnVdP0tkiG21jk-X0HRup4OsVaIeFoQHqTBsVbQtM | 34240 |
openmsistream/data_file_io/actor/file_registry/__init__.py | sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU | 0 |
openmsistream/data_file_io/actor/file_registry/producer_file_registry.py | sha256=-BBfNZv47yy4YvxAXYv4PZJQ_cN8WKONSpGuZwGoZMA | 13928 |
openmsistream/data_file_io/actor/file_registry/stream_handler_registries.py | sha256=aEbH8nz7mr0hYFjFrYVJuVGz5qbaD0w9Oy23DZIFZP8 | 16845 |
openmsistream/data_file_io/entity/__init__.py | sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU | 0 |
openmsistream/data_file_io/entity/data_file.py | sha256=jXlyEhnVEmZ52b_BNC-vE0ZIOq1_l72AD1dTKPzYty0 | 562 |
openmsistream/data_file_io/entity/data_file_chunk.py | sha256=S-O4ePHp_2vJZzoc4foHXLFCpJiP1T1RxWqpGUSYh6Y | 10086 |
openmsistream/data_file_io/entity/data_file_directory.py | sha256=nWE3WF1o599hc3oJQAl1op1ZBN_R_GcN1rzA4pv5GCw | 542 |
openmsistream/data_file_io/entity/download_data_file.py | sha256=JZSy3vq03XGNkbUyXUCAMsnR5aSbhz5GsSxgFcWGPO4 | 13393 |
openmsistream/data_file_io/entity/reproducer_message.py | sha256=4vspMnmZi7MrNtucAvhyjU4JF63C1YrDEKM0OS0CS4s | 1757 |
openmsistream/data_file_io/entity/upload_data_file.py | sha256=hbXTmJSG0EeydotJB70jmxFOr7ZiI9lQmaKrULcd7Io | 18219 |
openmsistream/data_file_io/entity/upload_directory_event_handler.py | sha256=LR_iIXFKPRjR8GMEiOOBgvDpVYYDtrNh0HMB4hfl33o | 6983 |
openmsistream/girder/__init__.py | sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU | 0 |
openmsistream/girder/girder_upload_stream_processor.py | sha256=Yfo3i7SQ4gA5bJr5CBRTrQr5hy1zF0gbMw_QkX9pIRo | 15228 |
openmsistream/kafka_wrapper/__init__.py | sha256=gy6gPadT8pjQ_CIkLLgky1Rz4yEMji1MHQ4IYKeh_x0 | 698 |
openmsistream/kafka_wrapper/config_file_parser.py | sha256=0Wj3XHfVvI0aIGrAACTB3q6T7MoNpRbcfJmhIDZ-0qM | 7020 |
openmsistream/kafka_wrapper/consumer_and_producer_group.py | sha256=wTrDrS6eHe9w33_sUHIiqK1ag0ID1xmYHw1W85Zfftw | 5751 |
openmsistream/kafka_wrapper/consumer_group.py | sha256=k5CvzWy6pUjP5_bBaUoGgIVmVpY2drxuhXNClRjRCVM | 9271 |
openmsistream/kafka_wrapper/controlled_message_processor.py | sha256=3aivvvIz3Fx3I_YEz2avO4wvPUgEer0LvFn3G6NhzYI | 9263 |
openmsistream/kafka_wrapper/controlled_message_reproducer.py | sha256=CqaTBsMp9aK6eOJkQdw-CMuw7zc7VWufwOoYwOnerBM | 13632 |
openmsistream/kafka_wrapper/openmsistream_consumer.py | sha256=q881sVYXBj-Slt4M6vc7tay0UHaaKaMjHQe_8MA0qgo | 20618 |
openmsistream/kafka_wrapper/openmsistream_kafka_crypto.py | sha256=IpkIYCemGXlm4YMPdsC8ho7ss_laNdd0-dX5JkUwc1k | 4436 |
openmsistream/kafka_wrapper/openmsistream_producer.py | sha256=kQiCGiqNg8z-gR-spW_HR9Oa-EZmorypfd5ip5yOjDA | 16208 |
openmsistream/kafka_wrapper/producer_group.py | sha256=2IYczGNaj1iteXn2z3W7M4hUEjcucz1mRtUj1WqFglk | 2852 |
openmsistream/kafka_wrapper/producible.py | sha256=bH90D8HpKBbzCAYFf1ARYpW-wI_1HfWE_J-U_Fm94h4 | 1428 |
openmsistream/kafka_wrapper/serialization.py | sha256=JzGBnP0bwzxwOz9kpiRGr_WzJ4DTmpIqI4CAMdUP_h8 | 9999 |
openmsistream/kafka_wrapper/utilities.py | sha256=xhVt_NYdtZqb_NQuz4zj1ZokB8hEvodDNeX4NddGAIg | 3061 |
openmsistream/kafka_wrapper/config_files/README.md | sha256=TIpO1bYMJyUWUt_QiIh7TgZuiYEmzKGbf6lijFGwICQ | 137 |
openmsistream/kafka_wrapper/config_files/local_broker_test.config | sha256=eyOMMBmS5_W6-EFBhlZ5G3ba1MhXPz5tsjsw91nBMco | 447 |
openmsistream/kafka_wrapper/config_files/local_broker_test_encrypted.config | sha256=lIs1hKiEC-BpVhzrMchCsfEhZzvKE3y8lk7_87iVwdk | 484 |
openmsistream/kafka_wrapper/config_files/local_broker_test_encrypted_2.config | sha256=Ajxv8cMn91fONDUt81ksPUjerAr4gfzjlAC-lsGRBnI | 486 |
openmsistream/kafka_wrapper/config_files/local_broker_test_heartbeats.config | sha256=bhDFzi2kjEpEk8PSYG7ZuzRB2LUc9EcqKTBmUAgcPhs | 499 |
openmsistream/kafka_wrapper/config_files/local_broker_test_metadata_rep_consumer.config | sha256=ee2FoJiRYu8VXlM3Zm8ApyLn-D6v2O3snDHTtFN9F4o | 189 |
openmsistream/kafka_wrapper/config_files/local_broker_test_s3_transfer.config | sha256=Zg7HP4flTFYJRPh5GPyvpJtmlJFEkuIcWUKYRIRqPUY | 561 |
openmsistream/kafka_wrapper/config_files/prod.config | sha256=jHdbDPP4jiKYrvNwbrrzsZ4oFXwpTHBZr74hW7rZtMs | 601 |
openmsistream/kafka_wrapper/config_files/test.config | sha256=bfM4l8I9YJ2YLBnXMqOVSsABX_xI-XqnjR5KFV8Nz28 | 600 |
openmsistream/kafka_wrapper/config_files/test_encrypted.config | sha256=yztjvThfuXDsZboUmKuWdLS14qD7f5gFk3K_VwApXaY | 637 |
openmsistream/kafka_wrapper/config_files/test_encrypted_2.config | sha256=v7KAq5ndkHeMnQjJvKbMuEMi5pW33XqbYcuRMZafpkE | 639 |
openmsistream/kafka_wrapper/config_files/test_heartbeats.config | sha256=Pj1mAw66Ic7hjSCW6azC3GVv4SrC6FvIsqKhP7wzN9E | 652 |
openmsistream/kafka_wrapper/config_files/test_metadata_rep_consumer.config | sha256=IzmW84SXNkxKKwHs-5RUkG5mBfJMcM0US2s4kAQqtiI | 342 |
openmsistream/kafka_wrapper/config_files/test_s3_transfer.config | sha256=6yLgoXQ8T5hYvzwtXmpSj_gQR7wQC313CO6T5r6Tv00 | 714 |
openmsistream/kafka_wrapper/config_files/testing_node/testing_node.config | sha256=Pk4QSOb5efJZX4ZMNdnn_WFmqSOzNoQ0ir7-21t64DM | 2348 |
openmsistream/kafka_wrapper/config_files/testing_node/testing_node.crypto | sha256=9rM1CxjaWFpy9jm2PqwLUo4XZYVRSfi_KDfBkTZPWB4 | 105 |
openmsistream/kafka_wrapper/config_files/testing_node/testing_node.seed | sha256=Gj1-RNzN0GVyw_6ZZCVmlZv_7j7XLqyezybCCVY8Io4 | 36 |
openmsistream/kafka_wrapper/config_files/testing_node_2/testing_node_2.config | sha256=tAPDjPz0MTU7Dwe8uM9cdLhfO8xI3vpffb38sgG3wrg | 1196 |
openmsistream/kafka_wrapper/config_files/testing_node_2/testing_node_2.crypto | sha256=S88jQ10zbTULeH8BiDn_hCHnoE7Z70YEI4j012DAhuA | 105 |
openmsistream/kafka_wrapper/config_files/testing_node_2/testing_node_2.seed | sha256=q7or5btMdSn-y-sVyLQLVVY7Ov_ppUqtE5UtkcOYIPU | 36 |
openmsistream/metadata_extraction/__init__.py | sha256=7eyx5mvsbAYttYhJNlnTDmCvDMeTAbtjk7uhLqzMjdk | 151 |
openmsistream/metadata_extraction/metadata_json_message.py | sha256=QJ4wPovO6g4yU9ji-gGbAraJsvDJo-28NUv2G_xlAu0 | 684 |
openmsistream/metadata_extraction/metadata_json_reproducer.py | sha256=4bX_P-PbfwdNKiKh-Yfc3N7zjxp73eyMvaitVV1knEs | 6559 |
openmsistream/s3_buckets/__init__.py | sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU | 0 |
openmsistream/s3_buckets/config_file_parser.py | sha256=PBHYIGa18t0VaLpgiMphDHDjrbRUQTO5dUbRHmUn4d8 | 598 |
openmsistream/s3_buckets/s3_data_transfer.py | sha256=iz2HZSHdKogGnqi0gRmJ_MxSnyOU0lyn9ZKLrZsZYkc | 1382 |
openmsistream/s3_buckets/s3_service.py | sha256=rrETU-AcP99HIsb2z9kPyzh1g1MoTuIF7g5KVOZchKI | 4033 |
openmsistream/s3_buckets/s3_transfer_stream_processor.py | sha256=tVwjkQ9iD3D552cPh3ebB2ghHygQQy0fGyZUF8Vme5o | 6785 |
openmsistream/services/__init__.py | sha256=V7GB_oHQh5Ts5zQ8It89CkM9D7DlcpaJ2Q6zPJB61Ik | 281 |
openmsistream/services/config.py | sha256=RLIZqMwmgzVSlkrxDKvSDkKhBlqE7JZvH-mzsSG_U6A | 2840 |
openmsistream/services/install_service.py | sha256=6juAuQstaQbSAY_OZOE6Hfxz26QJl3LT6vAZyKKZL_o | 2271 |
openmsistream/services/linux_service_manager.py | sha256=UiNQlIigXnlNWhGNxwhLNoaUWxAO78IZw41nmIdKpu8 | 9191 |
openmsistream/services/manage_service.py | sha256=nfxgq64xbsAG52vy6FNncFJu11SN-WHnKrWT8YF8iuY | 1416 |
openmsistream/services/service_manager_base.py | sha256=XVqOaU10tj7OVmfMRWj2LsC8Sm0treIn0fiCFRxjsDg | 22603 |
openmsistream/services/utilities.py | sha256=CQ8BOxLQDI7F2jfkxYHIY4XrSg-e0eZaaGujRmpVci0 | 5508 |
openmsistream/services/windows_service_manager.py | sha256=CVqNF4ZrFtS0Lr08HSh2fdtHTByDrXhYIolrN2tnmog | 12100 |
openmsistream/services/examples/__init__.py | sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU | 0 |
openmsistream/services/examples/runnable_example.py | sha256=f39TOvH-YDfw1l4j4QIkfeEz3h4v90dADtcl1NyfnnE | 1176 |
openmsistream/services/examples/script_example.py | sha256=cFAsLoL5Xe4-6S4dtto7jF25uliDW0wImh9Z6jUBNBk | 1285 |
openmsistream/tools/__init__.py | sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU | 0 |
openmsistream/tools/provision_wrapper.py | sha256=xJ5u_pRzp9-s6xVyNcxkO-wY85DHenPyogpxQIjp1Qs | 6717 |
openmsistream/tools/undecryptable_messages/__init__.py | sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU | 0 |
openmsistream/tools/undecryptable_messages/reproduce_undecryptable_messages.py | sha256=dR11CFmaOLmK6GLclLkAAAGwEqmdnUeSKXdhdN3Eyu8 | 3114 |
openmsistream/utilities/__init__.py | sha256=5J12pqs-kVVu1byw0dcaO9qVuo2EKJIuDME7v33WADw | 379 |
openmsistream/utilities/argument_parsing.py | sha256=dkazWFAFYgv6v5WakTpfH5Bk1Gpk3TIQi-cUvq0ennM | 12008 |
openmsistream/utilities/config.py | sha256=kzyzOsJx3tUiTnzQDkyFEh-K5zjn2idf6mLtUtYFJbo | 1561 |
openmsistream/utilities/config_file_parser.py | sha256=faMgUyWr3MzP4wfv1NtodQ-mJAYp7XpKfB41nmL_9RU | 3543 |
openmsistream/utilities/controlled_processes_heartbeats.py | sha256=UwCA002QDfnpt9Dy3jXCN1GMYKw9My0WsZyTaHfBSiI | 5715 |
openmsistream/utilities/dataclass_table.py | sha256=4vCofVjlWqb0n1MSDirUvLLEog5x-gMU_WaLum1iL98 | 22604 |
openmsistream/utilities/heartbeat_producibles.py | sha256=rBwepIJYWxa5gzkJgk-HFgrqQRDaNwpsS2thAgWM_AA | 3262 |
openmsistream-1.8.0.dist-info/LICENSE | sha256=ixuiBLtpoK3iv89l7ylKkg9rs2GzF9ukPH7ynZYzK5s | 35148 |
openmsistream-1.8.0.dist-info/METADATA | sha256=A0WeC-bw0til201qt38TBE17Ho5JqmPasQYGixxYjzU | 3699 |
openmsistream-1.8.0.dist-info/WHEEL | sha256=G16H4A3IeoQmnOrYV4ueZGKSjhipXx8zc8nu9FGlvMA | 92 |
openmsistream-1.8.0.dist-info/entry_points.txt | sha256=s8tP87cGOzIYOlSAIi5OclAz51N8ow0offODd9ildgQ | 745 |
openmsistream-1.8.0.dist-info/top_level.txt | sha256=VlSRIYdr4rYvU23nRGJ87fGXX4R6Gdt793O6m-UvekI | 14 |
openmsistream-1.8.0.dist-info/RECORD | — | — |
top_level.txt
openmsistream
entry_points.txt
DataFileDownloadDirectory = openmsistream.data_file_io.actor.data_file_download_directory:main
DataFileUploadDirectory = openmsistream.data_file_io.actor.data_file_upload_directory:main
GirderUploadStreamProcessor = openmsistream.girder.girder_upload_stream_processor:main
InstallService = openmsistream.services.install_service:main
ManageService = openmsistream.services.manage_service:main
ProvisionNode = openmsistream.tools.provision_wrapper:main
ReproduceUndecryptableMessages = openmsistream.tools.undecryptable_messages.reproduce_undecryptable_messages:main
S3TransferStreamProcessor = openmsistream.s3_buckets.s3_transfer_stream_processor:main
UploadDataFile = openmsistream.data_file_io.entity.upload_data_file:main