GG-33857 [IGNITE-12467] Transactions, rewrite async connections (#49)

(cherry picked from commit 9945ecb)

Author: isapego

docs/source/pyignite.aio_cluster.rst docs/source/pygridgain.aio_cluster.rstdocs/source/pyignite.aio_cluster.rst renamed to docs/source/pygridgain.aio_cluster.rst

@@ -13,7 +13,7 @@
     limitations under the License.
 
 pygridgain.datatypes package
-============================
+==========================
 
 .. automodule:: pygridgain.datatypes
     :members:
@@ -30,6 +30,8 @@ Submodules
    pygridgain.datatypes.cache_config
    pygridgain.datatypes.cache_properties
    pygridgain.datatypes.complex
+   pygridgain.datatypes.cluster_state
+   pygridgain.datatypes.expiry_policy
    pygridgain.datatypes.internal
    pygridgain.datatypes.key_value
    pygridgain.datatypes.null_object
@@ -38,4 +40,3 @@ Submodules
    pygridgain.datatypes.primitive_objects
    pygridgain.datatypes.sql
    pygridgain.datatypes.standard
-

docs/source/pyignite.cluster.rst docs/source/pygridgain.cluster.rstdocs/source/pyignite.cluster.rst renamed to docs/source/pygridgain.cluster.rst

@@ -0,0 +1,20 @@
+..  Copyright 2021 GridGain Systems, Inc. and Contributors.
+
+..  Licensed under the GridGain Community Edition License (the "License");
+    you may not use this file except in compliance with the License.
+    You may obtain a copy of the License at
+
+..      https://www.gridgain.com/products/software/community-edition/gridgain-community-edition-license
+
+..  Unless required by applicable law or agreed to in writing, software
+    distributed under the License is distributed on an "AS IS" BASIS,
+    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+    See the License for the specific language governing permissions and
+    limitations under the License.
+
+pygridgain.datatypes.transactions module
+=======================================
+
+.. automodule:: pygridgain.datatypes.transactions
+    :members:
+    :show-inheritance:

…rce/pyignite.datatypes.cluster_state.rst …e/pygridgain.datatypes.cluster_state.rstdocs/source/pyignite.datatypes.cluster_state.rst renamed to docs/source/pygridgain.datatypes.cluster_state.rst docs/source/pyignite.datatypes.cluster_state.rst renamed to docs/source/pygridgain.datatypes.cluster_state.rst

@@ -13,7 +13,7 @@
     limitations under the License.
 
 pygridgain package
-==================
+================
 
 .. automodule:: pygridgain
     :members:
@@ -38,6 +38,9 @@ Submodules
     pygridgain.aio_cache
     pygridgain.client
     pygridgain.aio_client
+    pygridgain.cluster
+    pygridgain.aio_cluster
+    pygridgain.transaction
     pygridgain.cursors
     pygridgain.exceptions
 

…rce/pyignite.datatypes.expiry_policy.rst …e/pygridgain.datatypes.expiry_policy.rstdocs/source/pyignite.datatypes.expiry_policy.rst renamed to docs/source/pygridgain.datatypes.expiry_policy.rst docs/source/pyignite.datatypes.expiry_policy.rst renamed to docs/source/pygridgain.datatypes.expiry_policy.rst

@@ -12,34 +12,10 @@
     See the License for the specific language governing permissions and
     limitations under the License.
 
-pygridgain package
-================
+pygridgain.transaction module
+=========================
 
-.. automodule:: pygridgain
+.. automodule:: pygridgain.transaction
     :members:
     :undoc-members:
     :show-inheritance:
-
-Subpackages
------------
-
-.. toctree::
-
-    pygridgain.datatypes
-    pygridgain.connection
-
-Submodules
-----------
-
-.. toctree::
-
-    pygridgain.binary
-    pygridgain.cache
-    pygridgain.aio_cache
-    pygridgain.client
-    pygridgain.aio_client
-    pygridgain.cluster
-    pygridgain.aio_cluster
-    pygridgain.cursors
-    pygridgain.exceptions
-

docs/source/pygridgain.datatypes.rst

@@ -16,6 +16,7 @@
 import asyncio
 from typing import Any, Iterable, Optional, Union
 
+from .api.tx_api import get_tx_connection
 from .datatypes import ExpiryPolicy
 from .datatypes.internal import AnyDataObject
 from .exceptions import CacheCreationError, CacheError, ParameterError
@@ -92,6 +93,9 @@ def __init__(self, client: 'AioClient', name: str, expiry_policy: ExpiryPolicy =
         super().__init__(client, name, expiry_policy)
 
     async def _get_best_node(self, key=None, key_hint=None):
+        tx_conn = get_tx_connection()
+        if tx_conn:
+            return tx_conn
         return await self.client.get_best_node(self, key, key_hint)
 
     async def settings(self) -> Optional[dict]: