@radaros/queue

Background job processing for RadarOS agents using BullMQ and Redis.

Install

npm install @radaros/queue bullmq ioredis

Quick Start

import { Agent, openai } from "@radaros/core";
import { AgentQueue, AgentWorker } from "@radaros/queue";

const agent = new Agent({ name: "assistant", model: openai("gpt-4o") });
const connection = { host: "localhost", port: 6379 };

const queue = new AgentQueue({ connection });
const worker = new AgentWorker({ agents: { assistant: agent }, connection });

await queue.enqueueAgentRun({ agentName: "assistant", input: "Hello!" });

Documentation

Full docs at radaros.mintlify.dev

License

MIT