pub struct XClaimOpts {
pub min_idle_ms: u64,
pub idle_override_ms: Option<u64>,
pub time_override_ms: Option<u64>,
pub retrycount_override: Option<u32>,
pub force: bool,
pub justid: bool,
}Expand description
Knobs for crate::StreamData’s xclaim: min-idle-ms plus the
IDLE/TIME/RETRYCOUNT/FORCE/JUSTID flag tail.
Fields§
§min_idle_ms: u64Only claim entries idle for at least this many ms.
idle_override_ms: Option<u64>Override post-claim idle to this many ms (else 0 — XCLAIM resets the clock so the new owner has the full idle window).
time_override_ms: Option<u64>Override post-claim delivery_time_ms to this absolute unix-ms.
Takes precedence over idle_override_ms if both set.
retrycount_override: Option<u32>Override post-claim delivery_count (else +=1).
force: boolFORCE: claim even if the entry isn’t in the PEL yet (creates
a fresh PEL row with delivery_count=1).
justid: boolJUSTID: skip the +=1 on delivery_count (used by tools that
don’t intend a real redelivery).
Auto Trait Implementations§
impl Freeze for XClaimOpts
impl RefUnwindSafe for XClaimOpts
impl Send for XClaimOpts
impl Sync for XClaimOpts
impl Unpin for XClaimOpts
impl UnsafeUnpin for XClaimOpts
impl UnwindSafe for XClaimOpts
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