message queue on redis stream v5+.
Redis stream queue
An async iterable interface for redis streams
This package provides support for the [RedisBloom](https://redis.io/docs/data-types/probabilistic/) module, which adds additional probabilistic data structures to Redis.
Returns the next buffer/object in a stream's readable queue
Promise queue with concurrency control
A really simple message queue based on Redis
Tiny queue data structure
simplified stream construction
Library for resuming and following streams in distributed systems
Queue data from a stream until a checkpoint is hit
Redis utilities for redis instrumentations
fast, tiny `queueMicrotask` shim for modern engines
Bull / BullMQ queue command line REPL
Job manager
Compatible version of p-queue
a streaming zip archive generator.
A robust, performance-focused and full-featured Redis client for Node.js.
A simple, fast, robust job/task queue, backed by Redis.
A modern, high performance Redis client
Node.js Streams, a user-land copy of the stream library from Node.js
A shim for the setImmediate efficient script yielding API
Redis Event Bus Module for Medusa
Check if something is a Node.js stream
Flamingo makes it easy to wade through the Twitter Streaming API by handling all connectivity and resource management for you. You just tell it what to track and consume the information in a resque queue. Flamingo isn't a traditional ruby gem. You don't require it into your code. Instead, it's designed to run as a daemon like redis or mysql. It provides a REST interface to change the parameters sent to the Twitter Streaming resource. All events from the streaming API are placed on a resque job queue where your application can process them. CAVEAT EMPTOR: This gem is alpha code so act accordingly.
Ruby binding for Honker — a SQLite-native task runtime. Queues, streams, pub/sub, time-trigger scheduler, results, locks, rate limits, all in one .db file. Thin wrapper around the Honker SQLite loadable extension; no Redis, no external broker.
No description provided.
No description provided.
No description provided.
No description provided.