ReplicatedMap Proxy for Asyncio Client (#783)

Straightforward port of ReplicatedMap proxy and its tests to the Asyncio Client

Author: yuce

hazelcast/asyncio/__init__.py

@@ -3,9 +3,17 @@
 warnings.warn("Asyncio API for Hazelcast Python Client is BETA. DO NOT use it in production.")
 del warnings
 
-__all__ = ["EntryEventCallable", "HazelcastClient", "List", "Map", "VectorCollection"]
+__all__ = [
+    "EntryEventCallable",
+    "HazelcastClient",
+    "List",
+    "Map",
+    "ReplicatedMap",
+    "VectorCollection",
+]
 
 from hazelcast.internal.asyncio_client import HazelcastClient
 from hazelcast.internal.asyncio_proxy.list import List
 from hazelcast.internal.asyncio_proxy.map import Map, EntryEventCallable
+from hazelcast.internal.asyncio_proxy.replicated_map import ReplicatedMap
 from hazelcast.internal.asyncio_proxy.vector_collection import VectorCollection

hazelcast/internal/asyncio_client.py

@@ -26,11 +26,13 @@
     LIST_SERVICE,
     MAP_SERVICE,
     ProxyManager,
+    REPLICATED_MAP_SERVICE,
     VECTOR_SERVICE,
 )
 from hazelcast.internal.asyncio_proxy.base import Proxy
 from hazelcast.internal.asyncio_proxy.list import List
 from hazelcast.internal.asyncio_proxy.map import Map
+from hazelcast.internal.asyncio_proxy.replicated_map import ReplicatedMap
 from hazelcast.internal.asyncio_reactor import AsyncioReactor
 from hazelcast.serialization import SerializationServiceV1
 from hazelcast.internal.asyncio_statistics import Statistics
@@ -272,6 +274,18 @@ async def get_map(self, name: str) -> Map[KeyType, ValueType]:
         """
         return await self._proxy_manager.get_or_create(MAP_SERVICE, name)
 
+    async def get_replicated_map(self, name: str) -> ReplicatedMap[KeyType, ValueType]:
+        """Returns the distributed ReplicatedMap instance with the specified
+        name.
+
+        Args:
+            name: Name of the distributed replicated map.
+
+        Returns:
+            Distributed ReplicatedMap instance with the specified name.
+        """
+        return await self._proxy_manager.get_or_create(REPLICATED_MAP_SERVICE, name)
+
     async def create_vector_collection_config(
         self,
         name: str,

hazelcast/internal/asyncio_proxy/manager.py

@@ -10,10 +10,12 @@
 from hazelcast.internal.asyncio_invocation import Invocation
 from hazelcast.internal.asyncio_proxy.base import Proxy
 from hazelcast.internal.asyncio_proxy.map import create_map_proxy
+from hazelcast.internal.asyncio_proxy.replicated_map import create_replicated_map_proxy
 from hazelcast.util import to_list
 
 LIST_SERVICE = "hz:impl:listService"
 MAP_SERVICE = "hz:impl:mapService"
+REPLICATED_MAP_SERVICE = "hz:impl:replicatedMapService"
 VECTOR_SERVICE = "hz:service:vector"
 
 _proxy_init: typing.Dict[
@@ -22,6 +24,7 @@
 ] = {
     LIST_SERVICE: create_list_proxy,
     MAP_SERVICE: create_map_proxy,
+    REPLICATED_MAP_SERVICE: create_replicated_map_proxy,
     VECTOR_SERVICE: create_vector_collection_proxy,
 }