@rocketqueue/memory

In-memory adapter for Rocketqueue queues.

Usage

import { MemoryAdapter } from "@rocketqueue/memory";
import { Queue, Worker } from "rocketqueue";

const adapter = new MemoryAdapter();

Works in both browser and server runtimes. State is instance-local and not persistent.

Dev

Typecheck:

bun --filter @rocketqueue/memory check-types

Build:

bun --filter @rocketqueue/memory build

Unit tests:

bun --filter @rocketqueue/memory test

Stress test:

bun --filter @rocketqueue/memory test:stress

Useful stress env vars:

• EVENTUALLY_MEMORY_STRESS_JOBS
• EVENTUALLY_MEMORY_STRESS_WORKERS
• EVENTUALLY_MEMORY_STRESS_CONCURRENCY
• EVENTUALLY_MEMORY_STRESS_TIMEOUT_MS
• EVENTUALLY_MEMORY_STRESS_POLL_INTERVAL_MS
• EVENTUALLY_MEMORY_STRESS_STAGGER_MS

Example:

EVENTUALLY_MEMORY_STRESS_JOBS=5000 \
EVENTUALLY_MEMORY_STRESS_WORKERS=8 \
EVENTUALLY_MEMORY_STRESS_CONCURRENCY=16 \
bun --filter @rocketqueue/memory test:stress

Notes

• close() is non-destructive and does not clear queue state.
• Use reset() when you want to explicitly clear all in-memory state.