pub enum IdempotencyDecision {
Fresh,
Replay {
status: u16,
body: Bytes,
},
InFlight,
Unavailable,
}Variants§
Fresh
Key claimed — run the handler, then complete or release.
Replay
A finished response exists — replay it verbatim.
InFlight
Another request with this key is currently executing.
Store unreachable — fail-open (run the handler, skip storing).
Auto Trait Implementations§
impl !Freeze for IdempotencyDecision
impl RefUnwindSafe for IdempotencyDecision
impl Send for IdempotencyDecision
impl Sync for IdempotencyDecision
impl Unpin for IdempotencyDecision
impl UnsafeUnpin for IdempotencyDecision
impl UnwindSafe for IdempotencyDecision
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<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
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> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request