vow-queue

vow-queue background job queue — Redis-backed (open_queue) or in-process via mem:redis. Install with vpm:

curl -fsSL https://install.vowlang.dev | sh
export PATH="$HOME/.local/bin:$PATH"
vpm add vow-queue@0.1.0 vow-redis@0.1.0
vpm install

Quick start

import vqueue from vow_queue

fn main(caps: Caps) -> int {
    return match caps.db {
        Some(cap) => with cap {
            let q = match vqueue.open_queue("mem:redis", "jobs") {
                Ok(queue) => queue,
                Err(_e) => return 1,
            };
            match vqueue.enqueue(q, "task-1") {
                Ok(_n) => {
                    match vqueue.dequeue(q) {
                        Ok(job) => {
                            print(job);
                            let _ = vqueue.close(q);
                            return 0;
                        },
                        Err(_e) => return 2,
                    }
                },
                Err(_e) => return 3,
            }
        },
        None => 0 - 1,
    };
}

Run tests

cd vow-libs/vow-queue && vow test tests/queue.vow -- --grant db:mem:redis

Next

Package ecosystem