✨ NATS server

Author: aleksul

pyproject.toml

@@ -57,6 +57,7 @@ requires-python = ">=3.10"
 [project.optional-dependencies]
 amqp = []
 kafka = ["aiokafka>=0.13.0,<0.14.0"]
+nats = ["nats-py>=2.14.0,<3.0.0"]
 pubsub = [
   "google-auth>=2.43.0",
   "grpcio>=1.76.0"

repid/connections/__init__.py

@@ -48,3 +48,8 @@
     from repid.connections.pubsub import PubsubServer
 
     __all__ += ["PubsubServer"]
+
+if is_installed("nats"):
+    from repid.connections.nats import NatsServer
+
+    __all__ += ["NatsServer"]

repid/connections/nats/__init__.py

@@ -0,0 +1 @@
+from repid.connections.nats.message_broker import NatsServer as NatsServer