Struct BacklogQuota 

pub struct BacklogQuota {
    pub limit_size: i64,
    pub limit_time: i32,
    pub policy: String,
}

Java BacklogQuota — one entry in the namespace-level backlog quota map. policy is a string (producer_request_hold, producer_exception, consumer_backlog_eviction) rather than a closed Rust enum so new broker enum values forward-decode cleanly.

-1 on either limit dimension disables that axis — missing fields default to -1 (not 0) so a broker-omitted dimension round-trips as “no quota”, never as “expire-everything” or “block-everything”.

Fields

limit_size: i64

Maximum allowed backlog in bytes (when type=destination_storage). -1 = unlimited.

limit_time: i32

Maximum allowed backlog age in seconds (when type=message_age). -1 = unlimited.

policy: String

Action when the quota is exceeded.

Trait Implementations

impl Clone for BacklogQuota

fn clone(&self) -> BacklogQuota

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BacklogQuota

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

Formats the value using the given formatter.

impl Default for BacklogQuota

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for BacklogQuota

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for BacklogQuota

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

where __S: Serializer,

Serialize this value into the given Serde serializer.