feat: Implemented SentinelBlockingConnectionPool.

CHANGES

@@ -1,3 +1,4 @@
+    * Add SentinelBlockingConnectionPool class
     * Move doctests (doc code examples) to main branch
     * Update `ResponseT` type hint
     * Allow to control the minimum SSL version

docs/connections.rst

@@ -35,6 +35,11 @@ SentinelConnectionPool
 .. autoclass:: redis.sentinel.SentinelConnectionPool
     :members:
 
+SentinelBlockingConnectionPool
+======================
+.. autoclass:: redis.sentinel.SentinelBlockingConnectionPool
+    :members:
+
 
 Cluster Client
 **************

redis/__init__.py

@@ -30,6 +30,7 @@
 )
 from redis.sentinel import (
     Sentinel,
+    SentinelBlockingConnectionPool,
     SentinelConnectionPool,
     SentinelManagedConnection,
     SentinelManagedSSLConnection,
@@ -77,6 +78,7 @@ def int_or_str(value):
     "RedisError",
     "ResponseError",
     "Sentinel",
+    "SentinelBlockingConnectionPool",
     "SentinelConnectionPool",
     "SentinelManagedConnection",
     "SentinelManagedSSLConnection",

redis/asyncio/__init__.py

@@ -9,6 +9,7 @@
 )
 from redis.asyncio.sentinel import (
     Sentinel,
+    SentinelBlockingConnectionPool,
     SentinelConnectionPool,
     SentinelManagedConnection,
     SentinelManagedSSLConnection,
@@ -53,6 +54,7 @@
     "RedisError",
     "ResponseError",
     "Sentinel",
+    "SentinelBlockingConnectionPool",
     "SentinelConnectionPool",
     "SentinelManagedConnection",
     "SentinelManagedSSLConnection",

redis/asyncio/sentinel.py

@@ -5,6 +5,7 @@
 
 from redis.asyncio.client import Redis
 from redis.asyncio.connection import (
+    BlockingConnectionPool,
     Connection,
     ConnectionPool,
     EncodableT,
@@ -97,14 +98,7 @@ class SentinelManagedSSLConnection(SentinelManagedConnection, SSLConnection):
     pass
 
 
-class SentinelConnectionPool(ConnectionPool):
-    """
-    Sentinel backed connection pool.
-
-    If ``check_connection`` flag is set to True, SentinelManagedConnection
-    sends a PING command right after establishing the connection.
-    """
-
+class _SentinelConnectionPoolMixin:
     def __init__(self, service_name, sentinel_manager, **kwargs):
         kwargs["connection_class"] = kwargs.get(
             "connection_class",
@@ -168,6 +162,27 @@ async def rotate_slaves(self) -> AsyncIterator:
         raise SlaveNotFoundError(f"No slave found for {self.service_name!r}")
 
 
+class SentinelConnectionPool(_SentinelConnectionPoolMixin, ConnectionPool):
+    """
+    Sentinel backed connection pool.
+
+    If ``check_connection`` flag is set to True, SentinelManagedConnection
+    sends a PING command right after establishing the connection.
+    """
+
+
+class SentinelBlockingConnectionPool(
+    _SentinelConnectionPoolMixin,
+    BlockingConnectionPool,
+):
+    """
+    Sentinel blocking connection pool.
+
+    If ``check_connection`` flag is set to True, SentinelManagedConnection
+    sends a PING command right after establishing the connection.
+    """
+
+
 class Sentinel(AsyncSentinelCommands):
     """
     Redis Sentinel cluster client

redis/sentinel.py

@@ -4,7 +4,12 @@
 
 from redis.client import Redis
 from redis.commands import SentinelCommands
-from redis.connection import Connection, ConnectionPool, SSLConnection
+from redis.connection import (
+    BlockingConnectionPool,
+    Connection,
+    ConnectionPool,
+    SSLConnection,
+)
 from redis.exceptions import ConnectionError, ReadOnlyError, ResponseError, TimeoutError
 from redis.utils import str_if_bytes
 
@@ -134,14 +139,7 @@ def rotate_slaves(self):
         raise SlaveNotFoundError(f"No slave found for {self.service_name!r}")
 
 
-class SentinelConnectionPool(ConnectionPool):
-    """
-    Sentinel backed connection pool.
-
-    If ``check_connection`` flag is set to True, SentinelManagedConnection
-    sends a PING command right after establishing the connection.
-    """
-
+class _SentinelConnectionPoolMixin:
     def __init__(self, service_name, sentinel_manager, **kwargs):
         kwargs["connection_class"] = kwargs.get(
             "connection_class",
@@ -195,6 +193,27 @@ def rotate_slaves(self):
         return self.proxy.rotate_slaves()
 
 
+class SentinelConnectionPool(_SentinelConnectionPoolMixin, ConnectionPool):
+    """
+    Sentinel backed connection pool.
+
+    If ``check_connection`` flag is set to True, SentinelManagedConnection
+    sends a PING command right after establishing the connection.
+    """
+
+
+class SentinelBlockingConnectionPool(
+    _SentinelConnectionPoolMixin,
+    BlockingConnectionPool,
+):
+    """
+    Sentinel blocking connection pool.
+
+    If ``check_connection`` flag is set to True, SentinelManagedConnection
+    sends a PING command right after establishing the connection.
+    """
+
+
 class Sentinel(SentinelCommands):
     """
     Redis Sentinel cluster client