Crate apalis_core

apalis-core

Utilities for building job and message processing tools. This crate contains traits for working with workers.

async fn run() {
    Monitor::new()
        .register_with_count(2, move |c| {
            WorkerBuilder::new(format!("tasty-banana-{c}"))
                .layer(TraceLayer::new())
                .with_storage(sqlite.clone())
                .build_fn(send_email)
        })
        .shutdown_timeout(Duration::from_secs(1))
        /// Here you could use tokio::ctrl_c etc
        .run_with_signal(async { Ok(()) }).await
}

Modules

• builder
  Represent utilities for creating worker instances.
• context
  Represents the [JobContext].
• error
  Includes all possible error types.
• executor
  Represents an executor. Currently tokio is implemented as default
• exposeexpose
  Utilities to expose workers and jobs to external tools eg web frameworks and cli tools
• job
  Includes the utilities for a job.
• job_fn
  Represents a service that is created from a function.
• layers
  Represents middleware offered through [tower::Layer]
• mock
  apalis mocking utilities
• monitor
  Represents monitoring of running workers
• mqmq
  Message queuing utilities
• request
  Represents the job bytes.
• response
  Represents different possible responses.
• storagestorage
  Represents ability to persist and consume jobs from storages.
• utils
  Represents extra utils needed for runtime agnostic approach
• worker
  Represents the utils for building workers.