Add compression option to kv

Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
nats-io · Oct 29, 2023 · 09afb0e · 09afb0e
1 parent 360e7c8
commit 09afb0e
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 3 deletions.
diff --git a/async-nats/src/jetstream/context.rs b/async-nats/src/jetstream/context.rs
@@ -644,6 +644,8 @@ impl Context {
                 num_replicas,
                 discard: stream::DiscardPolicy::New,
                 mirror_direct: config.mirror_direct,
+                #[cfg(feature = "server_2_10")]
+                compression: config.compression,
                 ..Default::default()
             })
             .await

diff --git a/async-nats/src/jetstream/kv/mod.rs b/async-nats/src/jetstream/kv/mod.rs
@@ -38,8 +38,8 @@ use super::{
     consumer::{push::OrderedError, DeliverPolicy, StreamError, StreamErrorKind},
     context::{PublishError, PublishErrorKind},
     stream::{
-        ConsumerError, ConsumerErrorKind, DirectGetError, DirectGetErrorKind, RawMessage,
-        Republish, Source, StorageType, Stream,
+        Compression, ConsumerError, ConsumerErrorKind, DirectGetError, DirectGetErrorKind,
+        RawMessage, Republish, Source, StorageType, Stream,
     },
 };
 
@@ -120,6 +120,9 @@ pub struct Config {
     pub sources: Option<Vec<Source>>,
     /// Allow mirrors using direct API.
     pub mirror_direct: bool,
+    /// Compression
+    #[cfg(feature = "server_2_10")]
+    pub compression: Option<Compression>,
 }
 
 /// Describes what kind of operation and entry represents

diff --git a/async-nats/src/jetstream/stream.rs b/async-nats/src/jetstream/stream.rs
@@ -1063,7 +1063,6 @@ pub struct Config {
     /// to [Compression::None], which is different from not overriding global config with anything.
     #[serde(default, skip_serializing_if = "Option::is_none")]
     pub compression: Option<Compression>,
-
     #[cfg(feature = "server_2_10")]
     /// Set limits on consumers that are created on this stream.
     #[serde(default, deserialize_with = "default_consumer_limits_as_none")]