Support google pubsub as adapter

README.md

@@ -17,6 +17,7 @@ Motivation: Redis provided on the cloud is usually only available within a VPC a
 ## Supported queue service
 
 - [x] AWS SQS
+- [x] Google PubSub
 
 Welcome to contribute more queue service, see [adapter/impl](./redis_canal/adapter/impl/) for more details.
 

pyproject.toml

@@ -25,8 +25,9 @@ classifiers = [
 ]
 
 [project.optional-dependencies]
-all = ["redis_canal[sqs]"]
+all = ["redis_canal[sqs, pubsub]"]
 sqs = ["boto3"]
+pubsub = ["google-cloud-pubsub"]
 test = [
     "pytest",
     "pytest-asyncio",

redis_canal/adapter/impl/pubsub.py

@@ -0,0 +1,17 @@
+import asyncio
+from functools import cached_property
+from typing import Awaitable
+
+from redis_canal.adapter.plugin import Adapter, hookimpl
+from redis_canal.log import logger
+from redis_canal.models import Message
+from redis_canal.tools import run_in_threadpool
+
+
+class PubSubAdapter(Adapter):
+    pass
+
+
+@hookimpl
+def register(manager):
+    manager.register(PubSubAdapter)