open-index/open-npm huggingface dataset:
npm package: @rocketqueue/memory
Description: In-memory adapter for Rocketqueue queues.
Author: HighX Lab
Latest version: 0.0.1

# `@rocketqueue/memory`

In-memory adapter for Rocketqueue queues.

## Usage

```ts
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:

```bash
bun --filter @rocketqueue/memory check-types
```

Build:

```bash
bun --filter @rocketqueue/memory build
```

Unit tests:

```bash
bun --filter @rocketqueue/memory test
```

Stress test:

```bash
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:

```bash
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.
npm package: @rocketqueue/redis
Description: Redis adapter for Rocketqueue queues.
Author: HighX Lab
Latest version: 0.1.1

# `@rocketqueue/redis`

Redis adapter for Rocketqueue queues.

## Dev

Typecheck:

```bash
bun --filter @rocketqueue/redis check-types
```

Build:

```bash
bun --filter @rocketqueue/redis build
```

## Local Redis

The integration and stress tests use `EVENTUALLY_REDIS_URL`.

Example:

```bash
export EVENTUALLY_REDIS_URL=redis://default:@localhost:6379
```

## Tests

Integration:

```bash
bun --filter @rocketqueue/redis test:integration
```

Stress:

```bash
bun --filter @rocketqueue/redis test:stress
```

Useful stress env vars:

- `EVENTUALLY_REDIS_STRESS_JOBS`
- `EVENTUALLY_REDIS_STRESS_WORKERS`
- `EVENTUALLY_REDIS_STRESS_CONCURRENCY`
- `EVENTUALLY_REDIS_STRESS_TIMEOUT_MS`
- `EVENTUALLY_REDIS_STRESS_POLL_INTERVAL_MS`
- `EVENTUALLY_REDIS_STRESS_LOCK_MS`
- `EVENTUALLY_REDIS_STRESS_STAGGER_MS`
- `EVENTUALLY_REDIS_STRESS_PREFIX`

Example:

```bash
EVENTUALLY_REDIS_URL=redis://default:@localhost:6379 \
EVENTUALLY_REDIS_STRESS_JOBS=5000 \
EVENTUALLY_REDIS_STRESS_WORKERS=8 \
EVENTUALLY_REDIS_STRESS_CONCURRENCY=16 \
bun --filter @rocketqueue/redis test:stress
```
npm package: @rocketqueue/ui
Description: React UI components and a standalone monitor app for Rocketqueue queues.
Author: HighX Lab
Latest version: 0.0.1

# `@rocketqueue/ui`

React UI components and a standalone monitor app for Rocketqueue queues.

## Library

Use the dashboard inside your own React app:

```tsx
import { EventuallyDashboard, EventuallyUIProvider } from "@rocketqueue/ui";
import "@rocketqueue/ui/styles.css"

export function App() {
  return (
    <EventuallyUIProvider endpoint="/api/playground">
      <EventuallyDashboard />
    </EventuallyUIProvider>
  );
}
```

## Standalone Monitor

Build the package:

```bash
bun --filter @rocketqueue/ui build
```

Start the monitor app:

```bash
node packages/eventually-ui/dist/cli.js start
```

By default the app uses `/api/playground` as its backend endpoint. Override it with `--endpoint` to point at your own queue backend:

```bash
node packages/eventually-ui/dist/cli.js start \
  --host 127.0.0.1 \
  --port 3210 \
  --endpoint https://your-backend.example.com/api/queues
```

Available flags:

- `--host`: host to bind the local monitor server. Default: `127.0.0.1`
- `--port`: port to bind the local monitor server. Default: `3210`
- `--endpoint`: Rocketqueue UI API endpoint used by the React app. Default: `/api/playground`

`start` only serves the built monitor app from `dist/standalone`. It does not create a queue backend server.