apalis 1.0.0-rc.9

Simple, extensible and multithreaded background task 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
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55

#![cfg_attr(docsrs, feature(doc_cfg))]
#![doc = include_str!("../README.md")]
//! ## Feature flags
#![cfg_attr(
    feature = "docsrs",
    cfg_attr(doc, doc = ::document_features::document_features!())
)]
//!
//! [`Service`]: https://docs.rs/tower/latest/tower/trait.Service.html
//! [`tower`]: https://crates.io/crates/tower
//! [`tower-http`]: https://crates.io/crates/tower-http
//! [`Layer`]: https://docs.rs/tower/latest/tower/trait.Layer.html
//! [`Stream`]: https://docs.rs/futures/latest/futures/stream/trait.Stream.html
#![warn(
    missing_debug_implementations,
    missing_docs,
    rust_2018_idioms,
    unreachable_pub
)]
/// apalis fully supports middleware via [`Layer`](https://docs.rs/tower/latest/tower/trait.Layer.html)
pub mod layers;

/// Common imports
pub mod prelude {
    pub use crate::layers::WorkerBuilderExt;
    pub use apalis_core::{
        backend::{
            Backend, BackendExt, Expose, FetchById, Filter, ListAllTasks, ListQueues, ListTasks,
            ListWorkers, Metrics, QueueInfo, RegisterWorker, Reschedule, ResumeAbandoned,
            ResumeById, RunningWorker, StatType, Statistic, TaskResult, TaskSink, TaskSinkError,
            TaskStream, Update, WaitForCompletion,
        },
        backend::{codec::*, custom::*, memory::*, pipe::*, poll_strategy::*, shared::*},
        error::*,
        layers::*,
        monitor::{ExitError, Monitor, MonitorError, MonitoredWorkerError, shutdown::Shutdown},
        task::Parts,
        task::Task,
        task::attempt::Attempt,
        task::builder::TaskBuilder,
        task::data::{AddExtension, Data},
        task::extensions::Extensions,
        task::metadata::MetadataExt,
        task::status::Status,
        task::task_id::RandomId,
        task::task_id::TaskId,
        task::task_id::TaskIdError,
        task_fn::{FromRequest, IntoResponse, TaskFn, task_fn},
        worker::builder::*,
        worker::ext::{
            ack::*, circuit_breaker::*, event_listener::*, long_running::*, parallelize::*,
        },
        worker::{Worker, context::WorkerContext, event::Event},
    };
}