Struct async_nats::jetstream::kv::Config

pub struct Config {
    pub bucket: String,
    pub description: String,
    pub max_value_size: i32,
    pub history: i64,
    pub max_age: Duration,
    pub max_bytes: i64,
    pub storage: StorageType,
    pub num_replicas: usize,
    pub republish: Option<Republish>,
    pub mirror: Option<Source>,
    pub sources: Option<Vec<Source>>,
    pub mirror_direct: bool,
}

Configuration values for key value stores.

Fields

bucket: String

Name of the bucket

description: String

Human readable description.

max_value_size: i32

Maximum size of a single value.

history: i64

Maximum historical entries.

max_age: Duration

Maximum age of any entry in the bucket, expressed in nanoseconds

max_bytes: i64

How large the bucket may become in total bytes before the configured discard policy kicks in

storage: StorageType

The type of storage backend, File (default) and Memory

num_replicas: usize

How many replicas to keep for each entry in a cluster.

republish: Option<Republish>

Republish is for republishing messages once persistent in the Key Value Bucket.

mirror: Option<Source>

Bucket mirror configuration.

sources: Option<Vec<Source>>

Bucket sources configuration.

mirror_direct: bool

Allow mirrors using direct API.

Trait Implementations

impl Debug for Config

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for Config

fn default() -> Config

Returns the “default value” for a type.