Merge pull request #2732 from subspace/nats-client

Introduce NATS client abstraction
autonomys · May 2, 2024 · 5b2d897 · 5b2d897
2 parents e63894e + d4a8725
commit 5b2d897
Show file tree

Hide file tree

Showing 5 changed files with 543 additions and 0 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/crates/subspace-farmer/Cargo.toml b/crates/subspace-farmer/Cargo.toml
@@ -14,6 +14,7 @@ include = [
 [dependencies]
 anyhow = "1.0.82"
 async-lock = "3.3.0"
+async-nats = "0.34.0"
 async-trait = "0.1.80"
 backoff = { version = "0.4.0", features = ["futures", "tokio"] }
 base58 = "0.2.0"
@@ -36,6 +37,7 @@ mimalloc = "0.1.41"
 num_cpus = "1.16.0"
 parity-scale-codec = "3.6.9"
 parking_lot = "0.12.2"
+pin-project = "1.1.5"
 prometheus-client = "0.22.2"
 rand = "0.8.5"
 rayon = "1.10.0"

diff --git a/crates/subspace-farmer/src/cluster.rs b/crates/subspace-farmer/src/cluster.rs
@@ -0,0 +1 @@
+pub mod nats_client;