{"library":"redis-x-stream","type":"library","category":null,"description":"An async iterable interface for Redis streams, built on top of ioredis and msgpackr. Version 4.1.0 supports Redis 5+ (6.2+ for claimIdleTime). Provides high-level modules for job queues with workers, retries, backoff, dead-letter queues (import from 'redis-x-stream/queue') and a distributed single-flight cache with two-tier storage (import from 'redis-x-stream/cache'). Features typed parsing, consumer group support with automatic PEL re-delivery, dynamic stream addition, dead consumer recovery via XAUTOCLAIM, flush timers for pending acks, and observability methods (info, groups, consumers, pending). Ships TypeScript declarations. Releases follow semver with monthly cadence.","language":"javascript","status":"active","version":"4.1.0","tags":["javascript","queue","stream","redis","tasks","redis-queue","job-queue","jobs","redis-stream","typescript"],"last_verified":"Sun Jun 07","install":[{"cmd":"npm install redis-x-stream","imports":["import { RedisStream } from 'redis-x-stream'","import { Queue, Worker } from 'redis-x-stream/queue'","import { SingleFlightCache } from 'redis-x-stream/cache'"]},{"cmd":"yarn add redis-x-stream","imports":[]},{"cmd":"pnpm add redis-x-stream","imports":[]}],"homepage":"https://github.com/calebboyd/redis-x-stream#readme","github":"https://github.com/calebboyd/redis-x-stream","docs":null,"changelog":null,"pypi":null,"npm":"redis-x-stream","openapi_spec":null,"status_page":null,"smithery":null,"compatibility":null}