Fourché

A simple task queue named after a lion with forked tail (queue fourché), works with Redis.

Repositories

This library is developed mainly on Codeberg.org, but the source code is hosted also on sourcehut.

Any patches, merge/pull requests or issues on those repositories are welcomed.

# the main branch is "trunk"
% git clone git@codeberg.org:grauwoelfchen/fourche.git
% git --no-pager branch -v
* trunk xxxxxxx XXX

Installation

# eg. async
% cargo install fourche --feature="async"

Example

use serde::{Deserialize, Serialize};

#[derive(Debug, Deserialize, Serialize)]
struct Job<T: Serialize> {
  id: T,
}

Sync

feature: sync (default)

use fourche::Queue;
use redis::Commands;

let client = redis::Client::open("redis://127.0.0.1:6379/0").unwrap();
let mut conn = client.get_connection().unwrap();

let job = Job::<i64> { id: 1 }

let mut queue = Queue::new("name", &mut conn);

// enqueue
if let Err(err) = queue.enqueue::<Job>(job) {
    println!("err: {}", err);
}

// dequeue
loop {
  match queue.dequeue::<Job>() {
    Ok(job) => println!("job: {}", job),
    Err(err) => {
        println!("err: {}", err);
        break;
    },
  }
}

Async

feature: async

use fourche::AsyncQueue;
use redis::AsyncCommands;

let client = redis::Client::open("redis://127.0.0.1:6379/1").unwrap();
let mut conn = client.get_multiplexed_async_connection().await.unwrap();

let job = Job::<i64> { id: 1 }

let mut queue = AsyncQueue::new("name", &mut conn);

// enqueue
if let Err(err) = queue.enqueue::<Job<_>>(job).await {
    println!("err: {}", err);
}

// dequeue
loop {
  match queue.dequeue::<Job>().await {
    Ok(job) => println!("job: {}", job),
    Err(err) => {
        println!("err: {}", err);
        break;
    },
  }
}

License

Fourche
Copyright 2019-2025 Yasha

Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at

   http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.