Struct nats::jetstream::StreamConfig [−][src]
pub struct StreamConfig {}Show fields
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
[src]
impl Clone for StreamConfig
[src]fn clone(&self) -> StreamConfig
[src]
pub fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Default for StreamConfig
[src]
impl Default for StreamConfig
[src]fn default() -> StreamConfig
[src]
impl<'de> Deserialize<'de> for StreamConfig
[src]
impl<'de> Deserialize<'de> for StreamConfig
[src]fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
[src]
__D: Deserializer<'de>,
impl From<&'_ StreamConfig> for StreamConfig
[src]
impl From<&'_ StreamConfig> for StreamConfig
[src]fn from(sc: &StreamConfig) -> StreamConfig
[src]
impl From<&'_ str> for StreamConfig
[src]
impl From<&'_ str> for StreamConfig
[src]fn from(s: &str) -> StreamConfig
[src]
impl Serialize for StreamConfig
[src]
impl Serialize for StreamConfig
[src]Auto Trait Implementations
impl RefUnwindSafe for StreamConfig
impl RefUnwindSafe for StreamConfig
impl Send for StreamConfig
impl Send for StreamConfig
impl Sync for StreamConfig
impl Sync for StreamConfig
impl Unpin for StreamConfig
impl Unpin for StreamConfig
impl UnwindSafe for StreamConfig
impl UnwindSafe for StreamConfig
Blanket Implementations
impl<T> DeserializeOwned for T where
T: for<'de> Deserialize<'de>,
[src]
impl<T> DeserializeOwned for T where
T: for<'de> Deserialize<'de>,
[src]impl<T> Same<T> for T
impl<T> Same<T> for T
type Output = T
Should always be Self
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,