Struct ConsumerSpec 

pub struct ConsumerSpec {
    pub durable_name: Option<String>,
    pub ack_wait_secs: Option<u32>,
    pub max_deliver: Option<i64>,
    pub backoff_secs: Vec<u32>,
    pub max_ack_pending: Option<i64>,
    pub batch: Option<u32>,
    pub deliver_policy: Option<DeliverPolicySpec>,
    pub filter_subjects: Vec<String>,
    pub concurrency: Option<u32>,
    pub dead_letter: Option<bool>,
}

Fields

durable_name: Option<String>

Bind, or create, exactly this durable; the platform never deletes it.

ack_wait_secs: Option<u32>

max_deliver: Option<i64>

-1 redelivers without limit.

backoff_secs: Vec<u32>

The delay before each redelivery, the last repeating.

max_ack_pending: Option<i64>

batch: Option<u32>

deliver_policy: Option<DeliverPolicySpec>

filter_subjects: Vec<String>

Filters beside the subscription’s subject, which is always one.

concurrency: Option<u32>

Messages handled at once per replica; 1 when unset.

dead_letter: Option<bool>

Whether a message given up on is published to the dead-letter stream; on when unset and ack is on_success.

Implementations

impl ConsumerSpec

pub const ACK_WAIT_SECS: RangeInclusive<u32>

pub const MAX_DELIVER: RangeInclusive<i64>

pub const UNLIMITED_DELIVERIES: i64 = -1

pub const MAX_BACKOFF_STEPS: usize = 10

pub const BACKOFF_SECS: RangeInclusive<u32>

pub const MAX_ACK_PENDING: RangeInclusive<i64>

pub const BATCH: RangeInclusive<u32>

pub const CONCURRENCY: RangeInclusive<u32>

Trait Implementations

impl Clone for ConsumerSpec

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConsumerSpec

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

Formats the value using the given formatter.

impl Default for ConsumerSpec

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for ConsumerSpec

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for ConsumerSpec

impl PartialEq for ConsumerSpec

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for ConsumerSpec

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for ConsumerSpec