Enum FreshnessPolicy
pub enum FreshnessPolicy {
Causal {
token: CommitToken,
max_wait: Duration,
},
Bounded {
max_lag_sequences: u64,
},
Available,
}Expand description
Freshness policy and commit token types used by projected queries. Projected-query freshness policy (ADR-0086 §3).
Wait/retry loops and wall clocks live outside the deterministic engine; the policy is a pure data shape the service layer interprets.
Variants§
Causal
Serve only once the projection frontier satisfies token.
Fields
§
token: CommitTokenRequired causal fence.
Bounded
Serve only if head-to-frontier lag is within max_lag_sequences.
Available
Serve the current published snapshot, reporting its frontier.
Trait Implementations§
§impl Clone for FreshnessPolicy
impl Clone for FreshnessPolicy
§fn clone(&self) -> FreshnessPolicy
fn clone(&self) -> FreshnessPolicy
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 more§impl Debug for FreshnessPolicy
impl Debug for FreshnessPolicy
impl Eq for FreshnessPolicy
§impl PartialEq for FreshnessPolicy
impl PartialEq for FreshnessPolicy
impl StructuralPartialEq for FreshnessPolicy
Auto Trait Implementations§
impl Freeze for FreshnessPolicy
impl RefUnwindSafe for FreshnessPolicy
impl Send for FreshnessPolicy
impl Sync for FreshnessPolicy
impl Unpin for FreshnessPolicy
impl UnsafeUnpin for FreshnessPolicy
impl UnwindSafe for FreshnessPolicy
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,
§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Checks if this value is equivalent to the given key. Read more
§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key and return true if they are equal.§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>
§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].