added async sentinel client

Author: amirreza8002

django_valkey/async_cache/client/__init__.py

@@ -1,2 +1,5 @@
-from .default import AsyncDefaultClient
-from .herd import AsyncHerdClient
+from django_valkey.async_cache.client.default import AsyncDefaultClient
+from django_valkey.async_cache.client.herd import AsyncHerdClient
+from django_valkey.async_cache.client.sentinel import AsyncSentinelClient
+
+__all__ = ["AsyncDefaultClient", "AsyncHerdClient", "AsyncSentinelClient"]

django_valkey/async_cache/client/sentinel.py

@@ -0,0 +1,44 @@
+from urllib.parse import parse_qs, urlparse
+
+from django.core.exceptions import ImproperlyConfigured
+from valkey.asyncio.sentinel import SentinelConnectionPool
+
+from django_valkey.async_cache.client.default import AsyncDefaultClient
+from django_valkey.client.sentinel import replace_query
+
+
+class AsyncSentinelClient(AsyncDefaultClient):
+    CONNECTION_FACTORY_PATH = (
+        "django_valkey.async_cache.pool.AsyncSentinelConnectionFactory"
+    )
+    """
+    Sentinel client which uses the single valkey URL specified by the CACHE's
+    LOCATION to create a LOCATION configuration for two connection pools; One
+    pool for the primaries and another pool for the replicas, and upon
+    connecting ensures the connection pool factory is configured correctly.
+    """
+
+    def __init__(self, server, params, backend):
+        if isinstance(server, str):
+            url = urlparse(server)
+            primary_query = parse_qs(url.query, keep_blank_values=True)
+            replica_query = primary_query
+            primary_query["is_master"] = [1]  # type: ignore
+            replica_query["is_master"] = [0]  # type: ignore
+
+            server = [replace_query(url, i) for i in (primary_query, replica_query)]
+
+        super().__init__(server, params, backend)
+
+    async def aconnect(self, *args, **kwargs):
+        connection = await super().aconnect(*args, **kwargs)
+        if not isinstance(connection.connection_pool, SentinelConnectionPool):
+            error_message = (
+                "Settings DJANGO_VALKEY_CONNECTION_FACTORY or "
+                "CACHE[].OPTIONS.CONNECTION_POOL_CLASS is not configured correctly."
+            )
+            raise ImproperlyConfigured(error_message)
+
+        return connection
+
+    connect = aconnect