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_closures 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 a row into lease_claims and completion writes
a closure tombstone into lease_claim_closures, both
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
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 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
Mutably borrows from an owned value. Read more
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>
Converts
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>
Converts
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