Add placement configuration to key-value store

nats-io · Oct 9, 2024 · 1d4a55b · 1d4a55b
1 parent 24239a4
commit 1d4a55b
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/src/NATS.Client.KeyValueStore/NatsKVConfig.cs b/src/NATS.Client.KeyValueStore/NatsKVConfig.cs
@@ -58,6 +58,11 @@ public record NatsKVConfig
     /// </summary>
     public NatsKVRepublish? Republish { get; init; }
 
+    /// <summary>
+    /// Placement requirements for a key-value store stream.
+    /// </summary>
+    public Placement? Placement { get; init; }
+
     /// <summary>
     /// Use compressed storage.
     /// </summary>

diff --git a/src/NATS.Client.KeyValueStore/NatsKVContext.cs b/src/NATS.Client.KeyValueStore/NatsKVContext.cs
@@ -223,6 +223,7 @@ private static StreamConfig CreateStreamConfig(NatsKVConfig config)
             Compression = config.Compression ? StreamConfigCompression.S2 : StreamConfigCompression.None,
             Storage = storage,
             Republish = republish!,
+            Placement = config.Placement,
             AllowRollupHdrs = true,
             DenyDelete = true,
             DenyPurge = false,