WIP: add redis broker driver [skip-ci]

docker-compose.yml

@@ -1,8 +1,13 @@
-version: '3.3'
+version: '3.7'
 
 services:
   rabbitmq:
     image: rabbitmq:4.0.2-management-alpine
     ports:
       - "5672:5672"
       - "15672:15672"
+
+  redis:
+    image: redis:7.4.1-alpine
+    ports:
+      - "6379:6379"

pyproject.toml

@@ -33,11 +33,13 @@ protobuf = {version = "^5.26.1", optional = true}
 googleapis-common-protos = {version = "^1.65.0", optional = true}
 aiormq = {version = "^6.8.1", optional = true}
 aiofiles = {version = "^24.1.0", optional = true}
+redis = {version = "^5.2.0", optional = true}
 
 [tool.poetry.extras]
 cli = ["aiofiles"]
 protobuf = ["protobuf", "googleapis-common-protos"]
 aiormq = ["aiormq"]
+redis = ["redis"]
 
 [tool.poetry.scripts]
 brokrpc = "brokrpc.cli:main"

src/brokrpc/abc.py

@@ -30,6 +30,7 @@ async def consume(self, inner: S, message: U) -> V:
         raise NotImplementedError
 
 
+# TODO: consider interface (e.g. make is_alive async)
 class BoundConsumer(metaclass=abc.ABCMeta):
     @abc.abstractmethod
     def is_alive(self) -> bool:

src/brokrpc/broker.py

@@ -268,6 +268,11 @@ def connect(options: BrokerConnectOptions) -> t.AsyncContextManager[BrokerDriver
 
         return AiormqBrokerDriver.connect(clean_options)
 
+    elif clean_options.driver == "redis":
+        from brokrpc.driver.redis import RedisBrokerDriver
+
+        return RedisBrokerDriver.connect(clean_options)
+
     else:
         details = "unsupported driver"
         raise ValueError(details, clean_options)