Cwab

Correct, efficient, and simple. Lets process some jobs.

Installation

The cwab library is installed by adding the following to your Cargo.toml

cwab = "^0.5"

You'll also need to run the following to install the CLI

cargo install cwab

Free Features

• Reliable job dispatch
• Error handling with retries
• Scheduled jobs
• An easy to use Rust API
• Middleware support

Paid Features

• Batched jobs
• Cron support
• Expiring jobs
• Unique jobs
• Encryption
• Rate limiting
• Parallelism
• Web UI
• Metrics
• Dedicated support
• A commercial license

To purchase

Use the below links to purchase a commercial license. You'll receive access to Cwab Pro within 24 hours after payment.

Click this link to pay $99 USD monthly

Click this link to pay $995 USD yearly

Documentation

You can find our documentation here

Basic use

Below is a basic implementation of a worker.

This example includes scheduling some jobs before starting the worker, which you would usually do on another machine.

To run, you'd run cwab librarian start in a separate shell to start the bookkeeping worker, and then run cargo run in your project.

use anyhow::Result;
use async_trait::async_trait;
use cwab::prelude::*;
use serde::{Deserialize, Serialize};

#[derive(Serialize, Deserialize, Copy, Clone, Debug)]
pub struct HelloJob;

#[async_trait]
impl Job for HelloJob {
    fn name(&self) -> &'static str {
        "HelloJob"
    }

    async fn perform(&self, input: Option<String>) -> Result<Option<String>, JobError> {
        let to_print = if let Some(i) = input {
            format!("Hello {:?}", i)
        } else {
             format!("Hello World")
        };
        println!("{}", to_print);
        Ok(None)
    }
}


#[tokio::main]
async fn main() -> Result<()> {
    let config = Config::new(None)?;
    let cwab = Cwab::new(&config)?;
    let mut worker = cwab.worker();
    worker.register(HelloJob)?;

    cwab.perform_async(HelloJob, None)
        .await
        .expect("Failed to schedule job");
    cwab.perform_async(HelloJob, Some("Bob".to_string()))
        .await
        .expect("Failed to schedule job");

    worker.start().await.expect("An unexpected error occurred");
    Ok(())
}