pub struct EnqueueOptions { /* private fields */ }Available on crate feature
jobs and (crate features model-mysql or model-postgres or model-sqlite) only.Expand description
How to enqueue one job (18.35.0): its queue, priority, when to run it, a uniqueness key and its retry count.
use std::time::Duration;
use rust_web_server::jobs::EnqueueOptions;
let options = EnqueueOptions::new()
.queue("mailers")
.priority(10)
.run_in(Duration::from_secs(60))
.unique("welcome:42")
.max_retries(5);Implementations§
Source§impl EnqueueOptions
impl EnqueueOptions
pub fn new() -> Self
Sourcepub fn queue(self, name: &str) -> Self
pub fn queue(self, name: &str) -> Self
The named queue (default default); workers can be limited to some
queues with PersistentJobQueue::queues.
Sourcepub fn priority(self, priority: i64) -> Self
pub fn priority(self, priority: i64) -> Self
Higher runs first among due jobs (default 0; negative is fine).
Sourcepub fn run_at(self, at: SystemTime) -> Self
pub fn run_at(self, at: SystemTime) -> Self
Not before at (second precision).
Sourcepub fn unique(self, key: &str) -> Self
pub fn unique(self, key: &str) -> Self
Skip the job when one with the same type and key is already
pending or running (enqueue_with
then answers that job’s id). Checked when enqueuing: two enqueues
in the same instant from different processes can both insert.
Sourcepub fn max_retries(self, n: u32) -> Self
pub fn max_retries(self, n: u32) -> Self
Retries after the first attempt (default: the queue’s, 3).
Trait Implementations§
Source§impl Clone for EnqueueOptions
impl Clone for EnqueueOptions
Source§impl Debug for EnqueueOptions
impl Debug for EnqueueOptions
Auto Trait Implementations§
impl Forget for EnqueueOptions
impl Freeze for EnqueueOptions
impl RefUnwindSafe for EnqueueOptions
impl Send for EnqueueOptions
impl Sync for EnqueueOptions
impl Unpin for EnqueueOptions
impl UnsafeUnpin for EnqueueOptions
impl UnwindSafe for EnqueueOptions
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,
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 moreSource§impl<T> Pointable for T
impl<T> Pointable for T
impl<T> Read<Exclusive, BecauseExclusive> for Twhere
T: ?Sized,
Source§impl<T> ServiceExt for T
impl<T> ServiceExt for T
Source§fn map_response_body<F>(self, f: F) -> MapResponseBody<Self, F>where
Self: Sized,
fn map_response_body<F>(self, f: F) -> MapResponseBody<Self, F>where
Self: Sized,
Available on crate feature
map-response-body only.Apply a transformation to the response body. Read more
Source§fn trace_for_http(self) -> Trace<Self, SharedClassifier<ServerErrorsAsFailures>>where
Self: Sized,
fn trace_for_http(self) -> Trace<Self, SharedClassifier<ServerErrorsAsFailures>>where
Self: Sized,
Available on crate feature
trace only.High level tracing that classifies responses using HTTP status codes. Read more
Source§fn trace_for_grpc(self) -> Trace<Self, SharedClassifier<GrpcErrorsAsFailures>>where
Self: Sized,
fn trace_for_grpc(self) -> Trace<Self, SharedClassifier<GrpcErrorsAsFailures>>where
Self: Sized,
Available on crate feature
trace only.High level tracing that classifies responses using gRPC headers. Read more