pub enum QueueServicePolicy {
Strict,
DurablePending,
}Expand description
What a dispatch does when its queue is not being served.
Variants§
Strict
Refuse rather than admit work onto a queue that cannot serve it. Structural unservability refuses immediately; a fleet condition refuses when the service-availability deadline expires. The default.
DurablePending
Accept, mark the run unserved immediately and visibly, and park durably until a compatible worker arrives. Written opt-in, per queue. Structural unservability still refuses — a queue no deployment declares can never be served, so pending on it would be the lie the policy exists to avoid.
Implementations§
Trait Implementations§
Source§impl Clone for QueueServicePolicy
impl Clone for QueueServicePolicy
Source§fn clone(&self) -> QueueServicePolicy
fn clone(&self) -> QueueServicePolicy
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 moreimpl Copy for QueueServicePolicy
Source§impl Debug for QueueServicePolicy
impl Debug for QueueServicePolicy
Source§impl Default for QueueServicePolicy
impl Default for QueueServicePolicy
Source§fn default() -> QueueServicePolicy
fn default() -> QueueServicePolicy
Returns the “default value” for a type. Read more
Source§impl<'de> Deserialize<'de> for QueueServicePolicy
impl<'de> Deserialize<'de> for QueueServicePolicy
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Source§impl Display for QueueServicePolicy
impl Display for QueueServicePolicy
impl Eq for QueueServicePolicy
Source§impl PartialEq for QueueServicePolicy
impl PartialEq for QueueServicePolicy
impl StructuralPartialEq for QueueServicePolicy
Auto Trait Implementations§
impl Freeze for QueueServicePolicy
impl RefUnwindSafe for QueueServicePolicy
impl Send for QueueServicePolicy
impl Sync for QueueServicePolicy
impl Unpin for QueueServicePolicy
impl UnsafeUnpin for QueueServicePolicy
impl UnwindSafe for QueueServicePolicy
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> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> DeserializeOwned for Twhere
T: for<'de> Deserialize<'de>,
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
Compare self to
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> IntoMaybeUndefined<T> for T
impl<T> IntoMaybeUndefined<T> for T
Source§fn into_maybe_undefined(self) -> MaybeUndefined<T>
fn into_maybe_undefined(self) -> MaybeUndefined<T>
Converts this value into a three-state builder argument.
Source§impl<T> IntoOption<T> for T
impl<T> IntoOption<T> for T
Source§fn into_option(self) -> Option<T>
fn into_option(self) -> Option<T>
Converts this value into an optional builder argument.
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