Add max_bytes config option to object store

nats-io · Jun 20, 2024 · e0e8e90 · e0e8e90
1 parent 9b392a4
commit e0e8e90
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
@@ -1119,6 +1119,7 @@ impl Context {
  description: config.description.clone(),
  subjects: vec![chunk_subject, meta_subject],
  max_age: config.max_age,
+ max_bytes: config.max_bytes,
  storage: config.storage,
  num_replicas: config.num_replicas,
  discard: DiscardPolicy::New,

diff --git a/async-nats/src/jetstream/object_store/mod.rs b/async-nats/src/jetstream/object_store/mod.rs
@@ -72,6 +72,8 @@ pub struct Config {
  /// Maximum age of any value in the bucket, expressed in nanoseconds
  #[serde(default, with = "serde_nanos")]
  pub max_age: Duration,
+ /// How large the storage bucket may become in total bytes.
+ pub max_bytes: i64,
  /// The type of storage backend, `File` (default) and `Memory`
  pub storage: StorageType,
  /// How many replicas to keep for each value in a cluster, maximum 5.