#job #tasks #tokio #persistence #status #save #back-end

simple_jobs

Very simple persistence layer on top of Tokio tasks

5 releases

0.2.2 Jun 11, 2022
0.2.1 May 30, 2022
0.2.0 May 30, 2022
0.1.1 Apr 25, 2022
0.1.0 Apr 25, 2022

#65 in #persistence

MIT license

21KB
414 lines

simple_jobs

Very simple persistent jobs

A simple wrapper for Tokio tasks, where the tasks are saved to a backend of choice, and they can be queried for their status.

As an example, the crate provides the implementation for saving tasks to the filesystem.

Defining the backend

The trait [Job] requires the functions Job::save and Job::load that save and restore the struct JobInfo.

Using the FSJob implementation

The struct FSJob implements the trait [Job] by saving and restoring the job information from the filesystem. Each job gets a unique file, constructed from the unique job id.

Example:

async fn example() -> std::io::Result<()> {
    let job: FSJob<u16, MyError> = FSJob::new("/tmp".into());
    let id = job.submit(|id, job| async move {
        Ok(0u16)
    })?;
    let info = job.load(id)?;
    println!("Job status: {:?}", info.status);
    Ok(())
}

License: MIT


lib.rs:

Very simple persistent jobs

A simple wrapper for Tokio tasks, where the tasks are saved to a backend of choice, and they can be queried for their status.

As an example, the crate provides the implementation for saving tasks to the filesystem.

Defining the backend

The trait [Job] requires the functions Job::save and Job::load that save and restore the struct JobInfo.

Using the FSJob implementation

The struct FSJob implements the trait [Job] by saving and restoring the job information from the filesystem. Each job gets a unique file, constructed from the unique job id.

Example:

async fn example() -> std::io::Result<()> {
    let job: FSJob<u16, MyError> = FSJob::new("/tmp".into());
    let id = job.submit(|id, job| async move {
        Ok(0u16)
    })?;
    let info = job.load(id)?;
    println!("Job status: {:?}", info.status);
    Ok(())
}

Dependencies

~5–16MB
~194K SLoC