Struct nats::jetstream::StreamConfig

pub struct StreamConfig {

    pub name: String,
    pub max_bytes: i64,
    pub max_msgs: i64,
    pub discard: DiscardPolicy,
    pub subjects: Option<Vec<String>>,
    pub retention: RetentionPolicy,
    pub max_consumers: isize,
    pub max_age: isize,
    pub max_msg_size: Option<i32>,
    pub storage: StorageType,
    pub num_replicas: usize,
    pub no_ack: Option<bool>,
    pub duplicate_window: Option<isize>,
    pub template_owner: Option<String>,
}

StreamConfig determines the properties for a stream. There are sensible defaults for most. If no subjects are given the name will be used as the only subject.

Fields

name: String

A name for the Stream. Must not have spaces, tabs or period . characters

max_bytes: i64

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

max_msgs: i64

How large the Stream may become in total messages before the configured discard policy kicks in

discard: DiscardPolicy

When a Stream has reached its configured max_bytes or max_msgs, this policy kicks in. DiscardPolicy::New refuses new messages or DiscardPolicy::Old (default) deletes old messages to make space

subjects: Option<Vec<String>>

Which NATS subjects to populate this stream with. Supports wildcards. Defaults to just the configured stream name.

retention: RetentionPolicy

How message retention is considered, Limits (default), Interest or WorkQueue

max_consumers: isize

How many Consumers can be defined for a given Stream, -1 for unlimited

max_age: isize

Maximum age of any message in the stream, expressed in microseconds

max_msg_size: Option<i32>

The largest message that will be accepted by the Stream

storage: StorageType

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

num_replicas: usize

How many replicas to keep for each message in a clustered JetStream, maximum 5

no_ack: Option<bool>

Disables acknowledging messages that are received by the Stream

duplicate_window: Option<isize>

The window within which to track duplicate messages.

template_owner: Option<String>

The owner of the template associated with this stream.

Trait Implementations

impl Clone for StreamConfig

fn clone(&self) -> StreamConfig

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for StreamConfig

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

Formats the value using the given formatter.

impl Default for StreamConfig

fn default() -> StreamConfig

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for StreamConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl From<&'_ StreamConfig> for StreamConfig

fn from(sc: &StreamConfig) -> StreamConfig

Performs the conversion.

impl From<&'_ str> for StreamConfig

fn from(s: &str) -> StreamConfig

Performs the conversion.

impl Serialize for StreamConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
    __S: Serializer, 

Serialize this value into the given Serde serializer.