pub enum BackpressurePolicy {
Reject,
DropOldestPerTenant,
DropNewestPerTenant,
Timeout {
wait: Duration,
},
}Expand description
Behavior when enqueue capacity limits are hit.
Variants§
Reject
Reject enqueue requests when limits are exceeded.
DropOldestPerTenant
Drop the oldest task from the same tenant and enqueue the new task.
DropNewestPerTenant
Drop the newest task from the same tenant and enqueue the new task.
Timeout
Wait for capacity up to wait, otherwise reject with timeout.
Trait Implementations§
Source§impl Clone for BackpressurePolicy
impl Clone for BackpressurePolicy
Source§fn clone(&self) -> BackpressurePolicy
fn clone(&self) -> BackpressurePolicy
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreAuto Trait Implementations§
impl Freeze for BackpressurePolicy
impl RefUnwindSafe for BackpressurePolicy
impl Send for BackpressurePolicy
impl Sync for BackpressurePolicy
impl Unpin for BackpressurePolicy
impl UnwindSafe for BackpressurePolicy
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