pub struct Config {Show 23 fields
pub durable_name: Option<String>,
pub name: Option<String>,
pub description: Option<String>,
pub deliver_policy: DeliverPolicy,
pub ack_policy: AckPolicy,
pub ack_wait: Duration,
pub max_deliver: i64,
pub filter_subject: String,
pub filter_subjects: Vec<String>,
pub replay_policy: ReplayPolicy,
pub rate_limit: u64,
pub sample_frequency: u8,
pub max_waiting: i64,
pub max_ack_pending: i64,
pub headers_only: bool,
pub max_batch: i64,
pub max_bytes: i64,
pub max_expires: Duration,
pub inactive_threshold: Duration,
pub num_replicas: usize,
pub memory_storage: bool,
pub metadata: HashMap<String, String>,
pub backoff: Vec<Duration>,
}
Fields§
§durable_name: Option<String>
Setting durable_name
to Some(...)
will cause this consumer
to be “durable”. This may be a good choice for workloads that
benefit from the JetStream
server or cluster remembering the
progress of consumers for fault tolerance purposes. If a consumer
crashes, the JetStream
server or cluster will remember which
messages the consumer acknowledged. When the consumer recovers,
this information will allow the consumer to resume processing
where it left off. If you’re unsure, set this to Some(...)
.
Setting durable_name
to None
will cause this consumer to
be “ephemeral”. This may be a good choice for workloads where
you don’t need the JetStream
server to remember the consumer’s
progress in the case of a crash, such as certain “high churn”
workloads or workloads where a crashed instance is not required
to recover.
name: Option<String>
A name of the consumer. Can be specified for both durable and ephemeral consumers.
description: Option<String>
A short description of the purpose of this consumer.
deliver_policy: DeliverPolicy
Allows for a variety of options that determine how this consumer will receive messages
ack_policy: AckPolicy
How messages should be acknowledged
ack_wait: Duration
How long to allow messages to remain un-acknowledged before attempting redelivery
max_deliver: i64
Maximum number of times a specific message will be delivered. Use this to avoid poison pill messages that repeatedly crash your consumer processes forever.
filter_subject: String
When consuming from a Stream with many subjects, or wildcards, this selects only specific incoming subjects. Supports wildcards.
filter_subjects: Vec<String>
Fulfills the same role as Config::filter_subject, but allows filtering by many subjects.
replay_policy: ReplayPolicy
Whether messages are sent as quickly as possible or at the rate of receipt
rate_limit: u64
The rate of message delivery in bits per second
sample_frequency: u8
What percentage of acknowledgments should be samples for observability, 0-100
max_waiting: i64
The maximum number of waiting consumers.
max_ack_pending: i64
The maximum number of unacknowledged messages that may be in-flight before pausing sending additional messages to this consumer.
headers_only: bool
Only deliver headers without payloads.
max_batch: i64
Maximum size of a request batch
max_bytes: i64
Maximum value of request max_bytes
max_expires: Duration
Maximum value for request expiration
inactive_threshold: Duration
Threshold for consumer inactivity
num_replicas: usize
Number of consumer replicas
memory_storage: bool
Force consumer to use memory storage.
metadata: HashMap<String, String>
§backoff: Vec<Duration>
Custom backoff for missed acknowledgments.
Trait Implementations§
source§impl<'de> Deserialize<'de> for Config
impl<'de> Deserialize<'de> for Config
source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
source§impl From<OrderedConfig> for Config
impl From<OrderedConfig> for Config
source§fn from(config: OrderedConfig) -> Self
fn from(config: OrderedConfig) -> Self
source§impl FromConsumer for Config
impl FromConsumer for Config
source§impl IntoConsumerConfig for &Config
impl IntoConsumerConfig for &Config
fn into_consumer_config(self) -> Config
source§impl IntoConsumerConfig for Config
impl IntoConsumerConfig for Config
fn into_consumer_config(self) -> Config
impl Eq for Config
impl StructuralPartialEq for Config
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§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
source§unsafe fn clone_to_uninit(&self, dst: *mut T)
unsafe fn clone_to_uninit(&self, dst: *mut T)
clone_to_uninit
)