Skip to main content

awa_worker/
lib.rs

1mod cancel_listener;
2pub mod client;
3mod completion;
4pub mod context;
5pub mod dispatcher;
6mod enqueue_specs;
7pub mod events;
8pub mod executor;
9pub mod heartbeat;
10#[cfg(feature = "http-worker")]
11pub mod http_worker;
12pub mod maintenance;
13pub mod metrics;
14mod runtime;
15mod storage;
16
17// Re-exports
18pub use awa_model::{
19    CallbackConfig, CronMissedFirePolicy, PartitionedQueue, PartitionedQueueError, PeriodicJob,
20    PeriodicJobBuilder,
21};
22pub use client::{
23    BuildError, Client, ClientBuilder, HealthCheck, QueueCapacity, QueueHealth,
24    TransitionWorkerRole,
25};
26pub use context::{CallbackGuard, CallbackToken, JobContext};
27pub use dispatcher::{QueueConfig, RateLimit};
28pub use enqueue_specs::EnqueueRequest;
29pub use events::{JobEvent, RescueReason, UntypedJobEvent};
30pub use executor::{JobError, JobResult, Worker};
31pub use maintenance::RetentionPolicy;
32pub use metrics::AwaMetrics;
33
34#[cfg(feature = "http-worker")]
35pub use http_worker::{HttpWorker, HttpWorkerConfig, HttpWorkerMode};