pub struct ClaimedEntry {Show 13 fields
pub queue: String,
pub priority: i16,
pub lane_seq: i64,
pub ready_slot: i32,
pub ready_generation: i64,
pub lease_slot: i32,
pub lease_generation: i64,
pub claim_slot: i32,
pub receipt_id: Option<i64>,
pub claim_batch_id: Option<i64>,
pub claim_batch_index: Option<i32>,
pub lease_claim_receipt: bool,
pub enqueue_shard: i16,
}Fields§
§queue: String§priority: i16§lane_seq: i64§ready_slot: i32§ready_generation: i64§lease_slot: i32§lease_generation: i64§claim_slot: i32ADR-023: the claim_slot partition this attempt’s receipt
evidence landed in. Receipt-closure paths use this to co-locate
explicit lease_claim_closures; compact successful receipt
completions keep claim-local evidence in
lease_claim_closure_batches instead.
receipt_id: Option<i64>Stable identity for immutable receipt claim evidence. Present for receipt-backed claims and used by the compact completion path to validate the exact claim attempt without row-locking it.
claim_batch_id: Option<i64>Compact claim batch row identity for zero-deadline receipt claims. Row-local receipt claims leave this unset.
claim_batch_index: Option<i32>One-based item position inside lease_claim_batches.*_ids arrays.
Present with claim_batch_id and used as an O(1) compact proof.
lease_claim_receipt: bool§enqueue_shard: i16The enqueue shard the row was claimed from. Routes the
terminal done_entries write onto the correct shard’s
(ready_slot, queue, priority, enqueue_shard, lane_seq) key
and is the join predicate for receipt and admin lookups that
touch queue_claim_heads / ready_entries / leases.
Trait Implementations§
Source§impl Clone for ClaimedEntry
impl Clone for ClaimedEntry
Source§fn clone(&self) -> ClaimedEntry
fn clone(&self) -> ClaimedEntry
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 ClaimedEntry
impl Debug for ClaimedEntry
impl Eq for ClaimedEntry
Source§impl<'a, R: Row> FromRow<'a, R> for ClaimedEntrywhere
&'a str: ColumnIndex<R>,
String: Decode<'a, R::Database> + Type<R::Database>,
i16: Decode<'a, R::Database> + Type<R::Database>,
i64: Decode<'a, R::Database> + Type<R::Database>,
i32: Decode<'a, R::Database> + Type<R::Database>,
Option<i64>: Decode<'a, R::Database> + Type<R::Database>,
Option<i32>: Decode<'a, R::Database> + Type<R::Database>,
bool: Decode<'a, R::Database> + Type<R::Database>,
impl<'a, R: Row> FromRow<'a, R> for ClaimedEntrywhere
&'a str: ColumnIndex<R>,
String: Decode<'a, R::Database> + Type<R::Database>,
i16: Decode<'a, R::Database> + Type<R::Database>,
i64: Decode<'a, R::Database> + Type<R::Database>,
i32: Decode<'a, R::Database> + Type<R::Database>,
Option<i64>: Decode<'a, R::Database> + Type<R::Database>,
Option<i32>: Decode<'a, R::Database> + Type<R::Database>,
bool: Decode<'a, R::Database> + Type<R::Database>,
Source§impl PartialEq for ClaimedEntry
impl PartialEq for ClaimedEntry
Source§fn eq(&self, other: &ClaimedEntry) -> bool
fn eq(&self, other: &ClaimedEntry) -> bool
self and other values to be equal, and is used by ==.impl StructuralPartialEq for ClaimedEntry
Auto Trait Implementations§
impl Freeze for ClaimedEntry
impl RefUnwindSafe for ClaimedEntry
impl Send for ClaimedEntry
impl Sync for ClaimedEntry
impl Unpin for ClaimedEntry
impl UnsafeUnpin for ClaimedEntry
impl UnwindSafe for ClaimedEntry
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<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
key and return true if they are equal.Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
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