pub struct DelayedDeliveryPolicies {
pub active: bool,
pub tick_time_millis: i64,
}Expand description
Java DelayedDeliveryPolicies — namespace-level switch + index-tick
granularity for the broker’s delayed-message delivery tracker.
Maps to org.apache.pulsar.common.policies.data.DelayedDeliveryPolicies.
tick_time controls how often the broker’s delay-index buckets are
re-evaluated; smaller values give tighter delivery accuracy at a
higher tracker cost.
The Java field name is tickTime (carrying a @JsonProperty("tickTime")
annotation), not tickTimeMillis. The unit is documented as
milliseconds (see the upstream class doc), but the wire key drops
the unit suffix — Jackson on the broker only binds the literal
tickTime.
Fields§
§active: boolWhether delayed delivery is enabled for the namespace.
tick_time_millis: i64Index-tick granularity in milliseconds. Wire key tickTime.
Trait Implementations§
Source§impl Clone for DelayedDeliveryPolicies
impl Clone for DelayedDeliveryPolicies
Source§fn clone(&self) -> DelayedDeliveryPolicies
fn clone(&self) -> DelayedDeliveryPolicies
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreimpl Copy for DelayedDeliveryPolicies
Source§impl Debug for DelayedDeliveryPolicies
impl Debug for DelayedDeliveryPolicies
Source§impl Default for DelayedDeliveryPolicies
impl Default for DelayedDeliveryPolicies
Source§fn default() -> DelayedDeliveryPolicies
fn default() -> DelayedDeliveryPolicies
Returns the “default value” for a type. Read more
Source§impl<'de> Deserialize<'de> for DelayedDeliveryPolicieswhere
DelayedDeliveryPolicies: Default,
impl<'de> Deserialize<'de> for DelayedDeliveryPolicieswhere
DelayedDeliveryPolicies: Default,
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>,
Deserialize this value from the given Serde deserializer. Read more
Auto Trait Implementations§
impl Freeze for DelayedDeliveryPolicies
impl RefUnwindSafe for DelayedDeliveryPolicies
impl Send for DelayedDeliveryPolicies
impl Sync for DelayedDeliveryPolicies
impl Unpin for DelayedDeliveryPolicies
impl UnsafeUnpin for DelayedDeliveryPolicies
impl UnwindSafe for DelayedDeliveryPolicies
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
Mutably borrows from an owned value. Read more