21 Repositories
Rust mpmc-queue Libraries
A simple, efficient Rust library for handling asynchronous job processing and task queuing.
job_queue Setup cargo add job_queue Usage Create a job use job_queue::{Error, Job, typetag, async_trait, serde}; #[derive(Debug, serde::Deserialize,
RocksDB-based queue with python bindings
RocksQ An inproc RocksDB-based queue with Python bindings. It is implemented in Rust. Features: max capacity limit in number of elements; size calcula
A lightweight distributed message queue. Like AWS SQS and RSMQ but on Postgres.
Postgres Message Queue (PGMQ) A lightweight distributed message queue. Like AWS SQS and RSMQ but on Postgres. Features Lightweight - Built with Rust a
A naive buffered/sync channel implementation in Rust, using the queue data structure
buffered-queue-rs Introduction This is my attempt at a simple and very naive buffered/synced queue implementation in Rust. The base thread-safe queue
Simple and flexible queue implementation for Rust with support for multiple backends (Redis, RabbitMQ, SQS, etc.)
Omniqueue Omniqueue is an abstraction layer over queue backends for Rust. It includes support for RabbitMQ, Redis streams, and SQS out of the box. The
A rocksdb.rs wrapper bringing stack and queue functionalities
RocksDB_sq (Stack & Queue) A Rust crate that adds stack and queue functionality to RocksDB. This crate provide a wrapper around a RocksDB database and
Pure, minimal, and scalable timers
timer-queue A pure, minimal, and scalable structure for tracking expiration of timers let mut q = TimerQueue::new(); q.insert(42, "second"); q.insert(
A scalable message queue powered by a segmented, partitioned, replicated and immutable log.
A scalable message queue powered by a segmented, partitioned, replicated and immutable log. This is currently a work in progress. laminarmq is intende
Message/job queue based on bonsaidb, similar to sqlxmq.
Bonsaimq Simple database message queue based on bonsaidb. The project is highly influenced by sqlxmq. Warning: This project is in early alpha and shou
Fast and easy-to-use event-driven network library.
message-io is a fast and easy-to-use event-driven network library. The library handles the OS socket internally and offers a simple event message API
A single-producer single-consumer Rust queue with smart batching
Batching Queue A library that implements smart batching between a producer and a consumer. In other words, a single-producer single-consumer queue tha
A better message queue built by rust
bettermq A better message queue built by rust I start this project to study Rust
A lock-free multi-producer multi-consumer unbounded queue.
lf-queue A lock-free multi-producer multi-consumer unbounded queue. Examples [dependencies] lf-queue = "0.1" Single Producer - Single Consumer: use lf
A dynamically prioritizable priority queue.
bheap A generic binary max heap implementation for implementing a dynamically prioritizable priority queue. This implementation uses a vector as the u
A lock-free thread-owned queue whereby tasks are taken by stealers in entirety via buffer swapping
Swap Queue A lock-free thread-owned queue whereby tasks are taken by stealers in entirety via buffer swapping. This is meant to be used [thread_local]
disk backed wal queue
Repository Template Queue like disk backed WAL Pronouced Quál - from the german wordrd for agony - because it is. Operations The basic concept is si
Beanstalk is a simple, fast work queue.
beanstalkd Simple and fast general purpose work queue.
wait-free spsc linked-list queue with individually reusable nodes
A wait-free single-producer single-consumer linked-list queue with individually reusable nodes.
A job queue built on sqlx and PostgreSQL.
sqlxmq A job queue built on sqlx and PostgreSQL. This library allows a CRUD application to run background jobs without complicating its deployment. Th
A priority queue for Rust with efficient change function.
PriorityQueue This crate implements a Priority Queue with a function to change the priority of an object. Priority and items are stored in an IndexMap
:stars: Manage your shell commands.
Pueue Pueue is a command-line task management tool for sequential and parallel execution of long-running tasks. Simply put, it's a tool that processes