Added a helper class ClusterKeyspaceNotifications that makes it easier to consume keyspace notifications from a Redis cluster.

Author: dmaier-redislabs

redis/__init__.py

@@ -11,6 +11,17 @@
     UnixDomainSocketConnection,
 )
 from redis.credentials import CredentialProvider, UsernamePasswordCredentialProvider
+from redis.keyspace_notifications import (
+    ClusterKeyspaceNotifications,
+    EventType,
+    KeyeventChannel,
+    KeyNotification,
+    KeyNotificationType,  # Backwards compatibility alias for EventType
+    KeyspaceChannel,
+    is_keyevent_channel,
+    is_keyspace_channel,
+    is_keyspace_notification_channel,
+)
 from redis.exceptions import (
     AuthenticationError,
     AuthenticationWrongNumberOfArgsError,
@@ -58,17 +69,26 @@ def int_or_str(value):
     "BlockingConnectionPool",
     "BusyLoadingError",
     "ChildDeadlockedError",
+    "ClusterKeyspaceNotifications",
     "Connection",
     "ConnectionError",
     "ConnectionPool",
     "CredentialProvider",
     "CrossSlotTransactionError",
     "DataError",
     "DriverInfo",
+    "EventType",
     "from_url",
     "default_backoff",
     "InvalidPipelineStack",
     "InvalidResponse",
+    "is_keyevent_channel",
+    "is_keyspace_channel",
+    "is_keyspace_notification_channel",
+    "KeyeventChannel",
+    "KeyNotification",
+    "KeyNotificationType",
+    "KeyspaceChannel",
     "MaxConnectionsError",
     "OutOfMemoryError",
     "PubSubError",