Struct HedgingOptions 

#[non_exhaustive]
pub struct HedgingOptions { /* private fields */ }

Configure publisher request hedging behavior.

Request hedging sends a duplicate publish request when an in-flight batch publish RPC exceeds a configured delay threshold, mitigating tail latency caused by slow backend tasks or transient network stalls.

Hedging uses a token bucket to rate-limit hedged RPCs. Successful publish RPCs refill fractional tokens, and sending a hedged RPC decrements 1 token.

Request hedging is only active for messages published without an ordering key. For ordered publishing (messages with an ordering key), hedging is disabled to preserve strict ordering guarantees.

Implementations

impl HedgingOptions

pub fn new() -> Self

Create a new instance.

pub fn set_delay<V: Into<Duration>>(self, v: V) -> Self

Set the delay before sending a hedged request.

Clamped between 100ms and 10s.

pub fn set_max_tokens<V: Into<u32>>(self, v: V) -> Self

Set the maximum number of tokens in the token bucket.

Clamped between 1 and 250.

pub fn set_refill_ratio<V: Into<f32>>(self, v: V) -> Self

Set the fraction of a token refilled per successful publish RPC.

Clamped between 0.001 and 0.2.

Trait Implementations

impl Clone for HedgingOptions

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 HedgingOptions

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

Formats the value using the given formatter.

impl Default for HedgingOptions

fn default() -> Self

Returns the “default value” for a type.

impl PartialEq for HedgingOptions

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for HedgingOptions