pub struct QueueStorageConfig {
pub schema: String,
pub queue_slot_count: usize,
pub lease_slot_count: usize,
pub claim_slot_count: usize,
pub queue_stripe_count: usize,
pub lease_claim_receipts: bool,
}Fields§
§schema: String§queue_slot_count: usize§lease_slot_count: usize§claim_slot_count: usizeNumber of child partitions the receipt ring splits
lease_claims, lease_claim_batches, and receipt-closure evidence
across (ADR-023).
Mirrors lease_slot_count: a small fixed set of slots
reclaimed by rotation + TRUNCATE rather than by row-level
DELETE.
queue_stripe_count: usize§lease_claim_receipts: boolUse the receipt-plane short path for zero-deadline jobs:
claim writes compact batches into lease_claim_batches for the
zero-deadline hot path, while deadline-backed attempts keep row-local
evidence in lease_claims for indexed deadline rescue. Compact claims
can still materialize into leases when the worker later needs mutable
attempt state. Successful compact
completion writes durable terminal history through
receipt_completion_batches and compact claim-local closure evidence
in lease_claim_closure_batches, or falls back to done_entries, while
non-success exits and cold terminal-delete paths materialize explicit
closures in lease_claim_closures.
Receipt claim evidence is reclaimed by claim-ring rotation +
TRUNCATE.
Default true.
Set to false to force every claim through the legacy
leases materialization path.
Trait Implementations§
Source§impl Clone for QueueStorageConfig
impl Clone for QueueStorageConfig
Source§fn clone(&self) -> QueueStorageConfig
fn clone(&self) -> QueueStorageConfig
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreSource§impl Debug for QueueStorageConfig
impl Debug for QueueStorageConfig
Auto Trait Implementations§
impl Freeze for QueueStorageConfig
impl RefUnwindSafe for QueueStorageConfig
impl Send for QueueStorageConfig
impl Sync for QueueStorageConfig
impl Unpin for QueueStorageConfig
impl UnsafeUnpin for QueueStorageConfig
impl UnwindSafe for QueueStorageConfig
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
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more