glide-mq

glide-mq

High-performance AI-native message queue for Node.js on Valkey/Redis Streams with a Rust NAPI core.

Quick Start

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: '[email protected]', 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));

When to Apply

Use this skill when:

• Creating or configuring queues, workers, or producers
• Adding jobs (single, bulk, delayed, priority)
• Setting up retries, backoff, or dead-letter queues
• Building job workflows (parent-child, DAGs, chains)
• Implementing fan-out broadcast patterns
• Configuring cron/interval schedulers
• Setting up connection options (TLS, IAM, AZ-affinity)
• Working with batch processing or rate limiting
• Tracking AI/LLM usage (tokens, cost, model) per job or flow
• Streaming LLM output tokens in real-time
• Implementing human-in-the-loop approval with suspend/resume
• Setting budget caps (tokens, cost) on workflow flows
• Configuring fallback chains for model/provider failover
• Dual-axis rate limiting (RPM + TPM) for LLM API compliance
• Aggregating rolling usage/cost summaries across queues
• Searching jobs by vector similarity (KNN) with Valkey Search
• Exposing queues or broadcasts over the HTTP proxy, including SSE endpoints
• Integrating with frameworks (Hono, Fastify, NestJS, Hapi)
• Deploying in serverless environments (Lambda, Vercel Edge)

Core API by Priority

Priority	Category	Impact	Reference
1	Queue & Job Operations	CRITICAL	references/queue.md
2	Worker & Processing	CRITICAL	references/worker.md
3	Connection & Config	HIGH	references/connection.md
4	Workflows & FlowProducer	HIGH	references/workflows.md
5	Broadcast (Fan-Out)	MEDIUM	references/broadcast.md
6	Schedulers (Cron/Interval)	MEDIUM	references/schedulers.md
7	Observability & Events	MEDIUM	references/observability.md
8	AI-Native Primitives	HIGH	references/ai-native.md
9	Vector Search	MEDIUM	references/search.md
10	Serverless & Testing	LOW	references/serverless.md