Add cluster orchestration support for Kafka and Zenoh

2025-05-21 17:33:24 +02:00
parent 699fca25e0
commit 4b89e5d33f
17 changed files with 385 additions and 30 deletions
--- a/crates/store/src/lib.rs
+++ b/crates/store/src/lib.rs
@@ -226,7 +226,11 @@ pub enum PubSubStore {
    #[cfg(feature = "redis")]
    Redis(Arc<backend::redis::RedisStore>),
    #[cfg(feature = "nats")]
-    Nats(Arc<backend::nats::NatsStore>),
+    Nats(Arc<backend::nats::NatsPubSub>),
+    #[cfg(feature = "zenoh")]
+    Zenoh(Arc<backend::zenoh::ZenohPubSub>),
+    #[cfg(feature = "kafka")]
+    Kafka(Arc<backend::kafka::KafkaPubSub>),
    #[default]
    None,
 }