glide-mq — скилл

---
name: glide-mq
description: >-
  Use when building or changing code that uses glide-mq, the Node.js job queue on
  Valkey/Redis Streams: queues, workers, retries, schedulers, workflows,
  broadcast, serverless producers, HTTP proxy, or its AI primitives (usage,
  streaming, suspend/resume, budgets, fallbacks, vector search).
license: Apache-2.0
metadata:
  author: glide-mq
  version: '0.18.0'
  tags: glide-mq, message-queue, valkey, redis, job-queue, worker, streams, ai-native, llm, vector-search
  sources: docs/USAGE.md, docs/ADVANCED.md, docs/WORKFLOWS.md, docs/BROADCAST.md, docs/SERVERLESS.md, docs/TESTING.md, docs/OBSERVABILITY.md
---

# glide-mq

Job queue for Node.js on Valkey/Redis Streams, with a Rust NAPI client and all queue logic in Valkey Server Functions (one `FCALL` per job operation). The API is close to BullMQ; the differences that bite are in connection config and a few method signatures.

## Quick Start

```typescript
import { Queue, Worker } from 'glide-mq';

const connection = { addresses: [{ host: 'localhost', port: 6379 }] };

const queue = new Queue('tasks', { connection });
await queue.add('send-email', { to: 'user@example.com', subject: 'Hello' });

const worker = new Worker(
  'tasks',
  async (job) => {
    console.log(`Processing ${job.name}:`, job.data);
    return { sent: true };
  },
  { connection, concurrency: 10 },
);

worker.on('completed', (job) => console.log(`Done: ${job.id}`));
worker.on('failed', (job, err) => console.error(`Failed: ${job.id}`, err.message));
```

## References

Read the file that matches the task; each holds the options, defaults and edge cases for its area.

| Area                                                                              | File                                                       |
| --------------------------------------------------------------------------------- | ---------------------------------------------------------- |
| Queues, adding jobs, retries, dedup, rate limits, job lookup                      | [references/queue.md](references/queue.md)                 |
| Workers, concurrency, batch mode, stalled jobs, sandboxing                        | [references/worker.md](references/worker.md)               |