From 8d53b3febcd286cc5db68640310d5608599c6a16 Mon Sep 17 00:00:00 2001
From: Tomasz Pietrek <tomasz@nats.io>
Date: Sun, 14 Apr 2024 20:46:27 +0200
Subject: [PATCH] Add placement to object store

Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
---
 async-nats/src/jetstream/context.rs          | 1 +
 async-nats/src/jetstream/object_store/mod.rs | 2 ++
 2 files changed, 3 insertions(+)

diff --git a/async-nats/src/jetstream/context.rs b/async-nats/src/jetstream/context.rs
index cccf52a28..cbc504741 100644
--- 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
index 8bc5cc0ca..76491dd1c 100644
--- 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.