Struct WorkerOpts 

pub struct WorkerOpts<Args, W: Worker<Args> + ?Sized> { /* private fields */ }

Implementations

impl<Args, W> WorkerOpts<Args, W>

where W: Worker<Args>,

pub fn new() -> Self

pub fn retry<RO>(self, retry: RO) -> Self

where RO: Into<RetryOpts>,

pub fn retry_queue<S: Into<String>>(self, retry_queue: S) -> Self

pub fn queue<S: Into<String>>(self, queue: S) -> Self

pub fn unique_for(self, unique_for: Duration) -> Self

pub fn into_opts(&self) -> EnqueueOpts

pub async fn perform_async( &self, redis: &RedisPool, args: impl Serialize + Send + 'static, ) -> Result<()>

pub async fn perform_in( &self, redis: &RedisPool, duration: Duration, args: impl Serialize + Send + 'static, ) -> Result<()>

Trait Implementations

impl<Args, W: Worker<Args>> Default for WorkerOpts<Args, W>

fn default() -> Self

Returns the “default value” for a type.

impl<Args, W: Worker<Args>> From<&WorkerOpts<Args, W>> for EnqueueOpts

fn from(opts: &WorkerOpts<Args, W>) -> Self

Converts to this type from the input type.