pub struct Reaper {
pub heartbeat_interval: Interval,
pub pool: PgPool,
}Expand description
Reaper is a background task that fixes stale jobs.
It periodically runs and:
- Check for stale jobs (not updated for some time but status =
running) - Marks jobs as failed when their attempt count exceeds the maximum allowed
Fields§
§heartbeat_interval: Interval§pool: PgPoolImplementations§
Auto Trait Implementations§
impl Freeze for Reaper
impl !RefUnwindSafe for Reaper
impl Send for Reaper
impl Sync for Reaper
impl Unpin for Reaper
impl UnsafeUnpin for Reaper
impl !UnwindSafe for Reaper
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> 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