apalis-core 1.0.0

Core for apalis: simple, extensible multithreaded background processing for Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

use crate::backend::Backend;

/// Allows resuming all abandoned tasks in the backend
pub trait ResumeAbandoned: Backend {
    /// Resume all abandoned tasks
    fn resume_abandoned(&mut self) -> impl Future<Output = Result<usize, Self::Error>> + Send;
}

/// Allows registering a worker with the backend
pub trait RegisterWorker: Backend {
    /// Registers a worker
    fn register_worker(
        &mut self,
        worker_id: String,
    ) -> impl Future<Output = Result<(), Self::Error>> + Send;
}

/// A generic filter to choose which workers to include in an operation
#[derive(Debug, Clone)]
#[non_exhaustive]
pub enum WorkerFilter {
    /// All workers except the provided one
    AllExcept(String),
    /// Only the provided one
    Only(String),
    /// No filter
    None,
}