awa-worker 0.6.0-alpha.2

Worker runtime for the Awa job queue
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

mod cancel_listener;
pub mod client;
mod completion;
pub mod context;
pub mod dispatcher;
pub mod events;
pub mod executor;
pub mod heartbeat;
#[cfg(feature = "http-worker")]
pub mod http_worker;
pub mod maintenance;
pub mod metrics;
mod runtime;
mod storage;

// Re-exports
pub use awa_model::{CallbackConfig, PeriodicJob, PeriodicJobBuilder};
pub use client::{
    BuildError, Client, ClientBuilder, HealthCheck, QueueCapacity, QueueHealth,
    TransitionWorkerRole,
};
pub use context::{CallbackGuard, CallbackToken, JobContext};
pub use dispatcher::{QueueConfig, RateLimit};
pub use events::{JobEvent, UntypedJobEvent};
pub use executor::{JobError, JobResult, Worker};
pub use maintenance::RetentionPolicy;
pub use metrics::AwaMetrics;

#[cfg(feature = "http-worker")]
pub use http_worker::{HttpWorker, HttpWorkerConfig, HttpWorkerMode};