Add placement to object store

Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
nats-io · Apr 19, 2024 · f06cacf · f06cacf
1 parent a2149cd
commit f06cacf
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/async-nats/src/jetstream/context.rs b/async-nats/src/jetstream/context.rs
@@ -1054,6 +1054,7 @@ impl Context {
                 } else {
                     None
                 },
+                placement: config.placement,
                 ..Default::default()
             })
             .await

diff --git a/async-nats/src/jetstream/object_store/mod.rs b/async-nats/src/jetstream/object_store/mod.rs
@@ -78,6 +78,8 @@ pub struct Config {
     pub num_replicas: usize,
     /// Sets compression of the underlying stream.
     pub compression: bool,
+    // Cluster and tag placement.
+    pub placement: Option<stream::Placement>,
 }
 
 /// A blob store capable of storing large objects efficiently in streams.