Added nats notifier.

.github/workflows/release.yml

@@ -40,7 +40,7 @@ jobs:
         uses: jwlawson/actions-setup-cmake@v2
       - name: Install build tools
         if: ${{ contains(matrix.platform.os-name, 'Linux') }}
-        run: sudo apt-get update -y && sudo apt-get install -y build-essential 
+        run: sudo apt-get update -y && sudo apt-get install -y build-essential
       - name: Build binary
         uses: houseabsolute/actions-rust-cross@v0
         with:

.github/workflows/test.yml

@@ -72,7 +72,7 @@ jobs:
       - name: start docker services
         run: docker compose up -d --wait
       - name: Run tests
-        run: cargo test
+        run: cargo test --jobs 1
         env:
           TEST_REDIS_URL: redis://localhost:6379/0
           TEST_AMQP_URL: amqp://guest:guest@localhost:5672

.gitignore

@@ -1,4 +1,5 @@
 .idea/
+.env
 .vscode/
 /target
 data/

Cargo.toml

@@ -52,6 +52,8 @@ fern = { version = "^0.7.0", features = ["colored"] }
 reqwest = { version = "^0.12.9", features = ["json"] }
 derive_more = { version = "^1.0.0", features = ["display", "from", "from_str"], default-features = false }
 rdkafka = { version = "0.37.0", features = ["cmake-build", "zstd"] }
+async-nats = "0.39.0"
+nkeys = "0.4.4"
 
 [target.'cfg(not(target_env = "msvc"))'.dependencies.tikv-jemallocator]
 version = "0.6"

docker-compose.yaml

@@ -67,3 +67,19 @@ services:
       KAFKA_CFG_CONTROLLER_LISTENER_NAMES: "CONTROLLER"
       KAFKA_CFG_AUTO_CREATE_TOPICS_ENABLE: "true"
       KAFKA_CFG_OFFSETS_TOPIC_REPLICATION_FACTOR: "1"
+  nats:
+    image: nats:2.10-alpine
+    ports:
+      - 4222:4222
+    command: [-m, "8222", "--jetstream"]
+    healthcheck:
+      test:
+        - "CMD"
+        - sh
+        - -c
+        - "wget http://localhost:8222/healthz -q -O - | xargs | grep ok || exit 1"
+      interval: 5s
+      timeout: 3s
+      retries: 20
+
+