a message queue by redis streams
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
Tiny queue data structure
A really simple message queue based on Redis
simplified stream construction
Library for resuming and following streams in distributed systems
Queue data from a stream until a checkpoint is hit
Bull / BullMQ queue command line REPL
fast, tiny `queueMicrotask` shim for modern engines
Redis utilities for redis instrumentations
a streaming zip archive generator.
Compatible version of p-queue
Job manager
A robust, performance-focused and full-featured Redis client for Node.js.
A modern, high performance Redis client
A simple, fast, robust job/task queue, backed by Redis.
OpenTelemetry instrumentation for `redis` database client for Redis
A shim for the setImmediate efficient script yielding API
Node.js Streams, a user-land copy of the stream library from Node.js
Redis Event Bus Module for Medusa
simplified stream construction
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.
No description provided.