diffusion

View on PyPIReverse Dependencies (2)

6.10.3 diffusion-6.10.3-1-py3-none-any.whl

Wheel Details

Project: diffusion
Version: 6.10.3
Filename: diffusion-6.10.3-1-py3-none-any.whl
Download: [link]
Size: 191105
MD5: 61fa9840855d77ef17d99d38e81e7666
SHA256: 8819f8a474a3ca00e234558e8d3e23dc810de093bf64930ffb9883d0320d4299
Uploaded: 2024-04-09 08:26:16 +0000

dist-info

METADATA

Metadata-Version: 2.1
Name: diffusion
Version: 6.10.3
Summary: Python SDK for Diffusion.
Author-Email: DiffusionData Limited <contact[at]diffusiondata.com>
Project-Url: homepage, https://www.diffusiondata.com/
License: Proprietary
Keywords: diffusion,cloud,websockets,data
Classifier: License :: Other/Proprietary License
Classifier: Environment :: Other Environment
Classifier: Development Status :: 4 - Beta
Requires-Python: <3.13,>=3.8
Requires-Dist: attrs (==21.*,>=21.4.0)
Requires-Dist: cbor2 (==5.*,>=5.1.2)
Requires-Dist: stringcase (==1.*,>=1.2.0)
Requires-Dist: structlog (==21.*,>=21.5.0)
Requires-Dist: typing-extensions (==4.*,>=4.0.1)
Requires-Dist: pydantic (<3.0.0,>=1.9.0)
Requires-Dist: diffusion-core (==0.*,>=0.0.62)
Requires-Dist: aiohttp (==3.*,>=3.6.2); python_version < "3.12"
Requires-Dist: aiohttp (==3.*,>=3.9.0); python_version >= "3.12"
Description-Content-Type: text/x-rst
[Description omitted; length: 941 characters]

WHEEL

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

RECORD

Path Digest Size
diffusion/__init__.py sha256=OjWoUbuUSxRY59e9v_-CfcyN9ibP-tZiN3SDMBym_Lg 248
diffusion/exceptions.py sha256=CSIUdHpDxqeoOjZB5qFglQit-LJezUJIBKLwsIOWd30 738
diffusion/py.typed sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
diffusion/datatypes/__init__.py sha256=jrO-kCxIjmsEvGvcmcMvUVq_ZRiSdD6R-5xWP3XKfqI 3642
diffusion/datatypes/exceptions.py sha256=mSCYJvyJBjMmnm8a84u7j91AdpII_WN3_n5UeRcbRs4 494
diffusion/datatypes/complex/__init__.py sha256=Jl1iERRcMsRESBhfP5E6FSAjuG5HL8I4E8FINOoOgGU 570
diffusion/datatypes/complex/jsondatatype.py sha256=Kiw6uDTdBt0j04V3nyW-tPhy8KZn3GxuYgrvaSK_DoM 2053
diffusion/datatypes/complex/recorddatatype.py sha256=LkefL6Nzh72jXF2uVDU4gIivAeoyX0P8Sh9xEb005bo 214
diffusion/datatypes/complex/unknowndatatype.py sha256=-Rm5rKNBEP7C7xd6qQZ6o5-DzH5qMvrdHO0owF0Yhjk 204
diffusion/datatypes/foundation/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
diffusion/datatypes/foundation/abstract.py sha256=n4Dut5_BeacC5y4RsSOFlSO4-xO6n5dPNsnNgt64cv0 7795
diffusion/datatypes/foundation/datatype.py sha256=z0wybUTRMJT6NAR4K8A8k_anKfCbAfR5jKGYQ0bLChg 2342
diffusion/datatypes/primitives/__init__.py sha256=oqo1q5n_x3qviHQ4zzWnSFksb3Db1-6TfLQjq2CLx_U 1541
diffusion/datatypes/primitives/binarydatatype.py sha256=gkgAWLQH-_XU6DzJ3TXuPk18jGKGHMxCYjvEsNI5RXc 2095
diffusion/datatypes/primitives/doubledatatype.py sha256=CKNyYmuDVerP1NIj1ud56rtF8yeBpU1G7oNvykn-91A 366
diffusion/datatypes/primitives/int64datatype.py sha256=rIAKWZ2g7IEk_uDfCPYkiKFVNJYAnsP967xHh9KE7I0 988
diffusion/datatypes/primitives/primitivedatatype.py sha256=2kZTJpmZR9YaTDCC-WLCXHQkX_ZW3GvZjoBJkPJ2zWY 1602
diffusion/datatypes/primitives/stringdatatype.py sha256=58qgf7iWj41ZHPqf_NJHoA7o9F00-TJNtRO5cXkuyzM 234
diffusion/datatypes/timeseries/__init__.py sha256=xMjwxwsAJxMq7wKTo8mZI7r72xoDMJLrQB5nf1aHt8o 11881
diffusion/datatypes/timeseries/py.typed sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
diffusion/datatypes/timeseries/time_series_event.py sha256=H_VoRR7hz6JUDh7PhqJCk6HGKM9R2-0UnGwYso9f0XM 20051
diffusion/datatypes/timeseries/time_series_event_metadata.py sha256=oDGs46GXl8u1lzU6m7pvAYD2jIoYqp6aosqf8uxljVk 2993
diffusion/datatypes/timeseries/types.py sha256=5CKgxT7pooHligIz-Ab1wVM1f65qEyxNDFALXsUXar8 1802
diffusion/features/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
diffusion/features/control/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
diffusion/features/control/metrics/__init__.py sha256=s8bxniYOfJ7xXFAgaPSTs-Ep83ZfT4XPA6MWMntvmAo 8907
diffusion/features/control/metrics/collector.py sha256=-_v-GUPeKgiZO7xGfE33g_ewD2JISwGK8CB7hI3gKA4 1174
diffusion/features/control/metrics/session_metrics.py sha256=PAvLrjplofpSFi19U6ngFRtx_3H83hthQXqBIhSl_Hw 5254
diffusion/features/control/metrics/topic_metrics.py sha256=SRCmYL6MfE2Vf3Vp6tfcczLb7dGE-DHgOpR2Jk1tsKU 6016
diffusion/features/control/session_trees/__init__.py sha256=UnRru-FFG-71yaVdks58wRL94dKv4m5QcyCZqs7Wof0 9502
diffusion/features/control/session_trees/branch_mapping.py sha256=twog1rs0VNhAd0iyCQXFlPp66LoiM4ldqWNE6POSADM 1148
diffusion/features/control/session_trees/branch_mapping_table.py sha256=OxsfBXNkk_yb9jmyFHo4UuY2oaVBUcCb7_RVo6Nyu3w 3423
diffusion/features/control/session_trees/invalid_branch_mapping_exception.py sha256=vI8Cseafyo8LBvoC0N5hn2COp3G9BBDymVRsFFhunks 838
diffusion/features/timeseries/__init__.py sha256=S1skzbbRKEUKj61BYOkbL2jNDoS9m1vuE93xF-lTS6g 18085
diffusion/features/timeseries/query/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
diffusion/features/timeseries/query/query_result.py sha256=iON9xHnDjCTnSrJFrVUzXP6icMkJ9zb-m9-RlrIgV3M 6756
diffusion/features/timeseries/query/range_query.py sha256=DHdupo6XgtksSvJ3orQ2_C9bpgiiYykgPvXk80brg5w 49846
diffusion/features/timeseries/query/range_query_parameters.py sha256=DCKlrWyfLUqtAXivP9iDTdT7ZUiAuE9pZauxO2Zz6ew 702
diffusion/features/topics/__init__.py sha256=CppxWZyoYo6qneMK67Qe3Al1iQhdxTbCQvqEr4D0wyU 12974
diffusion/features/topics/selectors.py sha256=KsPEuQrEab8kBijn55RisuNH7BlpLfR5HddZjUTLC6E 8127
diffusion/features/topics/streams.py sha256=n9ma85V79ceHa3Dfc-_XsQ9ZzEbwBbwOT-lTn77jRtI 3189
diffusion/features/topics/details/__init__.py sha256=mOjsmO3u7_69i21JrIqAk2gy0FY1LPVWWg2ME4_imqs 423
diffusion/features/topics/details/topic_specification.py sha256=vM9Ogpn-f72G3G43Z7SN9AsM_pjW0tWFIQHMRpgZpxo 43195
diffusion/features/topics/update/__init__.py sha256=Ts9kp8-vUq_XxspvkMMOPTpIm7t-bOtbs2eCH98au8g 5020
diffusion/features/topics/update/constraint_factory.py sha256=zkA3Z6bNgLyOT-YR22DwLrN82mRlauyCtRsdOYXqX7A 4572
diffusion/features/topics/update/constraints.py sha256=9hzOPmsjTIFTA6wOUqSZxPiVVueaMykouZK9eCBIsMc 13621
diffusion/handlers/__init__.py sha256=d5JZnOOVHCNWNLis2fw2FS3IoraC9x5cH_Z7NXYmUjI 4703
diffusion/internal/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
diffusion/internal/components.py sha256=AL-0UOYgbSS3wARdqpsjSLEPJ-6mnF8ZbmUAWzc_YZ0 677
diffusion/internal/encoder.py sha256=ET7EwdCvuNSKo-bnrxuvo8xodHXVwV_T9D-lphNqZS0 1523
diffusion/internal/exceptions.py sha256=up0eC7zVw7bS1uZjZQ1OSqKSqExDuLvFh85_KBJNtTY 507
diffusion/internal/utils.py sha256=u37oLKyXHcDUG6bXnB3KptDMcb564_eREeJAS4UIr2M 12605
diffusion/internal/encoded_data/__init__.py sha256=2s6imf0rMOsTSU023DPRaHi8hhoPEE03RCdedT7wV8k 452
diffusion/internal/encoded_data/abstract.py sha256=oz63ucy6HjSFju-W5Mfmw3VxMrCXoouNJwTSmeJxM9c 4832
diffusion/internal/encoded_data/exceptions.py sha256=MlSaj6Fq6lonpb3bsVkmKKIBAfz6UrRkhVBCK3AyZ4Q 494
diffusion/internal/encoded_data/generics.py sha256=1O9KU-3f2bjH-TCU3rS67k4AGyz3fBglIxsY1FgscaY 1928
diffusion/internal/encoded_data/scalars.py sha256=GEWM8jtieI9qRd8xbsj0cJooGJRlB9NUpOJPMA7cM7o 5381
diffusion/internal/generated/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
diffusion/internal/generated/services.py sha256=zwYyjNA-6KTLTwwWznERXFcTOZcVDYGOZ-extVOBYWI 10938
diffusion/internal/protocol/__init__.py sha256=0rQNaRMZ8SeonlXV6rxTF6Dl7MDsFbMnvF9_gAzv8wc 7186
diffusion/internal/protocol/conversations.py sha256=VCwo9jm3f-d65-VTCS4rEzgQhVTuIM0tvGdxZmuSMjU 10113
diffusion/internal/protocol/exceptions.py sha256=3lb79aWNmVJPIyhRSsP8xHiJMqwY3bIj9dvwi5A_b7U 3033
diffusion/internal/protocol/message_types.py sha256=GB79-wevnjfzQAFJutgt6OY8iF6zFNXXRdcQBT573KE 8325
diffusion/internal/protocol/properties.py sha256=HTSXFr7tLiCHFcjRbEAKVfoaqA3PMM2Ikmx23Xk_1FQ 11585
diffusion/internal/pydantic_compat/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
diffusion/internal/pydantic_compat/shared/__init__.py sha256=QU09gNeUaSzTYE5Ypqx5lOoigIkK_zDdxr9g1lC4syA 594
diffusion/internal/pydantic_compat/v1/__init__.py sha256=R87InpB7sH_vt3NqESiCw5SBcyNJ2_Zl6Gh_n2_EKMc 730
diffusion/internal/pydantic_compat/v1/dataclasses.py sha256=JhUhfzdXvMjlrfSWEvG_i_kkWrkfEqodudNTyZi4arI 742
diffusion/internal/pydantic_compat/v1/error_wrappers.py sha256=4ApeDijNb_Y9NSVVO-0pgBqKdqbP1f_6Lmzn9j5jVBY 748
diffusion/internal/pydantic_compat/v1/generics.py sha256=_MWuuOrdiRNddl_VHGnvQH9Torb8h6wzF8gh2POi0sc 736
diffusion/internal/pydantic_compat/v1/mypy.py sha256=SUETrxsV4SBc4QD7nyeX2-EgyV39xGPem4uz_dTChdM 685
diffusion/internal/serialisers/__init__.py sha256=pP8wKewwzDFDi9SAlSL0HUkSP444D1rPForWcWjLT74 1540
diffusion/internal/serialisers/attrs.py sha256=RydLfXy95WGH6RUUkKaamoKPhnhjG5EJ68G3ESRnxPQ 2618
diffusion/internal/serialisers/base.py sha256=IKJZPSkxDV51qfquxHFpMV7d73N887lB9jNapdU-X_g 18690
diffusion/internal/serialisers/compound.py sha256=O5s7KQTInDEXAUy4WuMLEkgXe4EqJMJzRew8lhZ-n6A 7666
diffusion/internal/serialisers/generic_model.py sha256=W12Z8S943dyVbJ7rq5wCRtG5othPDMzWfIuFpLDIyg8 14133
diffusion/internal/serialisers/primitives.py sha256=mHASZuulKTlgqZzxTOvB7PNsXoIN-ypipApgexA9oZ4 778
diffusion/internal/serialisers/pydantic.py sha256=n_g5yTtT7gGBdaniSQHEFamCrFOM-R-yvtCYuLcJDnU 1829
diffusion/internal/serialisers/spec.py sha256=LLBcmr9pC4Z2bC0oDWTaMERkycvQmzmiX66n3AtM2gg 42516
diffusion/internal/serialisers/timeseries.py sha256=Ph1SUUZ47pFMfFOmwt4i8zpHzpv8-DgbOXyEO3vXo9c 4108
diffusion/internal/services/__init__.py sha256=s8C37BUccWHoE9MeQk3uOBAiCgXgaJ7FAxWItWKSYpY 688
diffusion/internal/services/abstract.py sha256=U7RELscakLoG6pvesV3Oe5ahyMQ9oWAZq9WODgB49f4 14170
diffusion/internal/services/exceptions.py sha256=vvVIvSaK-vby_KSVY9Yp3uDqz3wEcz4ckZ6mgSpnTsk 406
diffusion/internal/services/locator.py sha256=WVWyI8muKTkYBfwyKOXr3PRnGY68zKC0JHtDX-FZYkQ 2001
diffusion/internal/services/messaging.py sha256=E3USc1DLJPttWelPS07QwjhtjG-DeqSsoxM8SxxVnuU 6822
diffusion/internal/services/session.py sha256=crXmTsNVdi5IZbPqMtJ6J6cGSQni5Y4D5aFZkAF04X8 1769
diffusion/internal/services/topics.py sha256=T1zfkPGIUpF138c-EYqAgha0ARgtLhOt1HrIZReJDhg 5667
diffusion/internal/session/__init__.py sha256=sjC_felAecwAqb_JZQ3BmYDQ5CMOqs32Vybvpddtsdo 7520
diffusion/internal/session/connection.py sha256=GL4JuQhB9M0EHB-yUb4actIuZ8K_0m8R0qKTPCoZV0c 9587
diffusion/internal/session/credentials.py sha256=7RAd86M1fXNqoT3qWq3yvFaIyMbD-I_uLMBjjUeKQUg 1678
diffusion/internal/session/error_reason.py sha256=buLhmsH9bPOBZ1Kfljx0XVcDdCik2j_eOUEdyB7eAUU 4290
diffusion/internal/session/exception_handler.py sha256=K3c0M8Mju1W9a_xsr11eLgj_j3UHpidPWshvmSVWNkE 8161
diffusion/internal/session/session_attributes_core.py sha256=feDkNIInfXc5ai3y6cVOLgPyG3t2mmnWOdq1iMeanv4 4169
diffusion/internal/session/locks/__init__.py sha256=agh5kUpwlVuo4lTHC8srGxzEE4SQ2wDR0Z1yQ9wOTDw 416
diffusion/internal/session/locks/session_lock_acquisition.py sha256=8tGuqLXONSy8uUTwa-ApyEzE49xpYQbUOA31dmwzDfw 1359
diffusion/internal/session/locks/session_lock_request.py sha256=Y2ucymU5E107EcwS6uEy1lWDSfsPKRiY_HGl7zKCBr4 805
diffusion/internal/session/locks/session_lock_request_cancellation.py sha256=rZsd6oJy396z9UkiUZPaDK4V2kAO-TRZ1SZpAsCBgo4 710
diffusion/internal/timeseries/__init__.py sha256=agh5kUpwlVuo4lTHC8srGxzEE4SQ2wDR0Z1yQ9wOTDw 416
diffusion/internal/timeseries/query/__init__.py sha256=agh5kUpwlVuo4lTHC8srGxzEE4SQ2wDR0Z1yQ9wOTDw 416
diffusion/internal/timeseries/query/range_query.py sha256=uv0p2Xch3gyN_6vV9KrMnLwCSJYDAS7RHQ_EvAAHlPE 2355
diffusion/internal/timeseries/query/range_query_parameters.py sha256=0-cJ4ev5RQC5It_WgSG3sr5y-qx6mQZjY59MwUa8gnM 27415
diffusion/internal/timeseries/query/range_query_request.py sha256=cP4Pz8bBtQN2F6RIZ5Fb2GQQwVrUHcK2lV9J2j8WeWk 3799
diffusion/internal/timeseries/query/range_query_result.py sha256=TmS7JaO2nLh9oT-7MzuTDJxCEaTJtm2bPq6eVXaWXIc 11089
diffusion/internal/topics/__init__.py sha256=ieRGrrTwclmftbD7U0QYmf6Gd-dtu6PUAg6BWURV070 7618
diffusion/internal/topics/constraints.py sha256=X3t0Vd36lFFk0VduyIREdg5PGJaY0F323sHfOFddvsY 311
diffusion/internal/validation/__init__.py sha256=x191zVokczsnjQHbdtD8hcza_XP9BgWj3yTFf95w288 2191
diffusion/internal/validation/pydantic.py sha256=me35pvMFevpjjlg90a_TZ9d9aY6vnRKQPhlny9RcOko 1963
diffusion/messaging/__init__.py sha256=fjVIiV0pzwL3ufhMwoYo_4gzVgaEFxPiXIow9I9TNPs 10373
diffusion/session/__init__.py sha256=1Hgol5TU3ElsLZfMpDYypGkEzUX39__ps9MtEnmqjlk 13722
diffusion/session/exceptions.py sha256=diOiZ-yKgJ1dO8J87T7NGFQvxdy3mvu8Ly59QQmwKjc 5948
diffusion/session/retry_strategy.py sha256=L8bavEy6zG_VtUbc8l6DKeApCmET9_TcyHaTbvKi90U 2214
diffusion/session/session_container_factory.py sha256=lHi2rIElGauntdaouqh-hm2W7uFZ89pcnsowApAqq-E 1489
diffusion/session/session_factory.py sha256=fUqlMW-iLXQiURR_mmeHTfwmk2eQRcWYGbr5LYJ1Hx0 15075
diffusion/session/locks/__init__.py sha256=mOjsmO3u7_69i21JrIqAk2gy0FY1LPVWWg2ME4_imqs 423
diffusion/session/locks/session_lock_acquisition.py sha256=TY7yM3f5Ajpa9Ccyc6qIyBdeBJc7JO1anfmMkfrf6es 921
diffusion/session/locks/session_locks.py sha256=GCeQmLZLgXaWHssnB0LEh-vPls2rnxVefzVTNyT4Alc 15402
diffusion-6.10.3.dist-info/METADATA sha256=WzAu6qeniY7rBUbS0tFzJp6nJUDzELR8aHV5X_wgDn8 1826
diffusion-6.10.3.dist-info/WHEEL sha256=ExAwMQyqPPAklMrxzDqhEpq-U2yADelmMQC3M8EDYNk 101
diffusion-6.10.3.dist-info/top_level.txt sha256=7Q6zKfH0egqajYyKZcvu9BaNkgK3lP6IuD3_eQzyME0 10
diffusion-6.10.3.dist-info/RECORD

top_level.txt

diffusion