Struct AsyncWorker

pub struct AsyncWorker<Ctx, T>
where
    Ctx: Clone + Send + Sync + 'static,
    T: DeserializeOwned + Send + Sync,
{ /* private fields */ }

Implementations

impl<Ctx, T> AsyncWorker<Ctx, T>

where Ctx: Clone + Send + Sync + 'static, T: DeserializeOwned + Send + Sync,

pub fn new<S>(prefix: S) -> Self

where S: Into<String>,

pub fn with_timeout(self, timeout: u64) -> Self

pub fn with_lease_duration(self, lease_duration: u64) -> Self

pub fn with_num_workers(self, num_workers: usize) -> Self

pub fn producer(&self, client: Arc<Pool>) -> Producer

pub async fn recover<C: AsyncCommands>(&self, db: &mut C) -> Result<()>

pub fn run(self, work: impl Work<Ctx, T> + 'static) -> Self