pub struct QueueConfigRow {
pub name: String,
pub max_workers: i32,
pub paused: bool,
pub retain_done_for_days: i32,
pub retain_dead_for_days: i32,
pub backoff_enabled: bool,
pub backoff_base_seconds: i32,
pub backoff_max_seconds: i32,
pub throttle_attempts: i32,
pub throttled_until: Option<DateTime<Utc>>,
pub updated_at: DateTime<Utc>,
}Fields§
§name: String§max_workers: i32§paused: bool§retain_done_for_days: i32§retain_dead_for_days: i32§backoff_enabled: boolOpt-in toggle for the configurable exponential throttle curve. When false, throttle finalizes use a flat fallback (60s) — the pre-toggle behavior of every queue.
backoff_base_seconds: i32§backoff_max_seconds: i32§throttle_attempts: i32Consecutive queue-wide throttles. Drives the backoff exponent
(base * 2^throttle_attempts); reset to 0 when any job on the
queue completes. This is the curve’s real driver — the per-job
JobRecord::throttle_attempts is a diagnostic counter only.
throttled_until: Option<DateTime<Utc>>Cool-down deadline. While in the future, claim_next refuses to
hand out rows for this queue so the whole fleet backs off
together. None unless the queue is actively throttled.
updated_at: DateTime<Utc>Trait Implementations§
Source§impl Clone for QueueConfigRow
impl Clone for QueueConfigRow
Source§fn clone(&self) -> QueueConfigRow
fn clone(&self) -> QueueConfigRow
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 moreSource§impl Debug for QueueConfigRow
impl Debug for QueueConfigRow
Source§impl<'de> Deserialize<'de> for QueueConfigRow
impl<'de> Deserialize<'de> for QueueConfigRow
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
Auto Trait Implementations§
impl Freeze for QueueConfigRow
impl RefUnwindSafe for QueueConfigRow
impl Send for QueueConfigRow
impl Sync for QueueConfigRow
impl Unpin for QueueConfigRow
impl UnsafeUnpin for QueueConfigRow
impl UnwindSafe for QueueConfigRow
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<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> 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