pub(crate) struct ClaimedRegistration {
registration: CreditRegistration,
expected_state: CreditRegistrationState,
}Expand description
A claimed row. Every answer and refusal is written against it, and lands only if the row is
still in Self::expected_state: the decision was made from a snapshot that the request, or
just the gap since the claim, may have let another writer overtake.
Fields§
§registration: CreditRegistration§expected_state: CreditRegistrationStateImplementations§
Source§impl ClaimedRegistration
impl ClaimedRegistration
Sourcepub(crate) fn moved_to(
registration: CreditRegistration,
in_flight: CreditRegistrationState,
) -> Self
pub(crate) fn moved_to( registration: CreditRegistration, in_flight: CreditRegistrationState, ) -> Self
The claim moves the row into in_flight before the request leaves.
Sourcepub(crate) fn left_in_place(registration: CreditRegistration) -> Self
pub(crate) fn left_in_place(registration: CreditRegistration) -> Self
The claim leaves the row where it stands, such as a verify lease or a parked check.
Sourcepub(crate) fn registration(&self) -> &CreditRegistration
pub(crate) fn registration(&self) -> &CreditRegistration
The row as claimed: its state is the one it had before the claim moved it.
pub(crate) fn id(&self) -> Uuid
Sourcepub(crate) fn into_registration(self) -> CreditRegistration
pub(crate) fn into_registration(self) -> CreditRegistration
The row back, to be claimed again as expecting the state the claim’s own move just wrote.
pub(crate) fn expected_state(&self) -> CreditRegistrationState
pub(crate) fn facts(&self, now: DateTime<Utc>) -> RowFacts
Auto Trait Implementations§
impl Freeze for ClaimedRegistration
impl RefUnwindSafe for ClaimedRegistration
impl Send for ClaimedRegistration
impl Sync for ClaimedRegistration
impl Unpin for ClaimedRegistration
impl UnsafeUnpin for ClaimedRegistration
impl UnwindSafe for ClaimedRegistration
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
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§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§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request§impl<L> LayerExt<L> for L
impl<L> LayerExt<L> for L
§fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
Applies the layer to a service and wraps it in [
Layered].§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
§impl<T> ServiceExt for T
impl<T> ServiceExt for T
§fn map_response_body<F>(self, f: F) -> MapResponseBody<Self, F>where
Self: Sized,
fn map_response_body<F>(self, f: F) -> MapResponseBody<Self, F>where
Self: Sized,
Apply a transformation to the response body. Read more
§fn decompression(self) -> Decompression<Self>where
Self: Sized,
fn decompression(self) -> Decompression<Self>where
Self: Sized,
Decompress response bodies. Read more
§fn trace_for_http(self) -> Trace<Self, SharedClassifier<ServerErrorsAsFailures>>where
Self: Sized,
fn trace_for_http(self) -> Trace<Self, SharedClassifier<ServerErrorsAsFailures>>where
Self: Sized,
High level tracing that classifies responses using HTTP status codes. Read more
§fn trace_for_grpc(self) -> Trace<Self, SharedClassifier<GrpcErrorsAsFailures>>where
Self: Sized,
fn trace_for_grpc(self) -> Trace<Self, SharedClassifier<GrpcErrorsAsFailures>>where
Self: Sized,
High level tracing that classifies responses using gRPC headers. Read more