async_nats::jetstream::kv

Struct Config

pub struct Config {Show 14 fields
    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,
    pub compression: bool,
    pub placement: Option<Placement>,
}

Expand description

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.

§compression: bool

Available on crate feature server_2_10 only.

Compression

§placement: Option<Placement>

Cluster and tag placement for the bucket.

Trait Implementations§

impl Debug for Config

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

Formats the value using the given formatter. Read more

impl Default for Config

fn default() -> Config

Returns the “default value” for a type. Read more

Auto Trait Implementations§

impl Freeze for Config

impl RefUnwindSafe for Config

impl Send for Config

impl Sync for Config

impl Unpin for Config

impl UnwindSafe for Config

Blanket Implementations§

impl<T> Any for T
where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> Borrow<T> for T
where T: ?Sized,

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for T
where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

impl<T, U> Into<U> for T
where U: From<T>,

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T> Same for T

type Output = T

Should always be Self

impl<T, U> TryFrom<U> for T
where U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more

impl<T> ErasedDestructor for T
where T: 'static,

impl<T> MaybeSendSync for T