Job Queue based on Genstage with retries, deduplication and replies.
Simple Elixir jobs pool
Lightweight job processing with GenStage.
A simple queue abstraction library to support leasing and buffering in Elixir.
A module which extends the erlang queue module.
Background jobs OTP style
Robust job queue compatible with Sidekiq Enterprise, powered by GenStage and Redis
Declare job workers that can be run by a variety of queuing backends. This plugin is a port of the Rails ActiveJob gem
A priority search queue implementation for Elixir.
Simple elixir work queue consumption for RabbitMQ
Priority Queue
A simple Phoenix Live Dashboard for Oban jobs
Simple queue implementation for webhooks and event sources.
This application reads from a redis queue (RPOP) and then executes functions from a list. The first function from the list does not rece...
Priority Queue for Elixir. Heap implementation
Shared inter-process queues
A simple FIFO Queue, with optional prioritisation
A light-weight job queue (think DAG) manager.
A wrapper for Erlang's :queue. Build First In, First Out queues.
An ultrafast double-ended queue, scored sorted set and key value database with an optional secondary u64 index.
A high-performance double-ended queue (deque) based on ETS
A FIFO queue wrapped around GenServer.
Real-time purely functional persistent (in the data-structure sense not that it's goes to disk) queue
A Heap-based Priority Queue Implementation in Elixir.
Utility to buffer items into a queue that follow a simple block pattern on calls to push and pop when the queue at a max size or empty.
An Elixir in memory work queue.
An Elixir wrapper around the Erlang optimized `queue` that supports the FIFO, first-in first-out, pattern. This is useful is when you ca...
Simple and reliable background job processing library for Elixir. Has persistence, retries, delayed jobs, concurrency limiting, error ha...
Job Queue based on Genstage with retries, deduplication and replies.
BlockingQueue is a simple queue implemented as a GenServer. It has a fixed maximum length established when it is created.
Message queue framework, with support for middleware and multiple adapters.