create-vorsteh-queue@0.1.6

Patch Changes

• aa22a40: update deps

@vorsteh-queue/core@0.5.0

Minor Changes

• aa22a40: Dynamic Schema & Table Names
  • All adapters (Drizzle, Kysely, Prisma) now support configurable schema and table names for queue jobs.
  • Enables an easier integration in existing DB setups.

@vorsteh-queue/adapter-prisma@0.4.0

Minor Changes

• aa22a40: Dynamic Schema & Table Names
  • All adapters (Drizzle, Kysely, Prisma) now support configurable schema and table names for queue jobs.
  • Enables an easier integration in existing DB setups.

Patch Changes

• Updated dependencies [aa22a40]
  • @vorsteh-queue/core@0.5.0

@vorsteh-queue/adapter-kysely@0.3.0

Minor Changes

• aa22a40: Dynamic Schema & Table Names
  • All adapters (Drizzle, Kysely, Prisma) now support configurable schema and table names for queue jobs.
  • Enables an easier integration in existing DB setups.

Patch Changes

• Updated dependencies [aa22a40]
  • @vorsteh-queue/core@0.5.0

@vorsteh-queue/adapter-drizzle@0.5.0

Minor Changes

• aa22a40: Dynamic Schema & Table Names
  • All adapters (Drizzle, Kysely, Prisma) now support configurable schema and table names for queue jobs.
  • Enables an easier integration in existing DB setups.

Patch Changes

• Updated dependencies [aa22a40]
  • @vorsteh-queue/core@0.5.0

create-vorsteh-queue@0.1.5

Patch Changes

• 35f7171: update dependencies

@vorsteh-queue/core@0.4.0

Minor Changes

Added

• Batch processing support: You can now register batch handlers via queue.registerBatch, allowing the queue to process multiple jobs at once according to configurable batch sizes and timing.
• New batch configuration options: minSize, maxSize, and waitFor allow fine-grained control over when and how batches are processed.
• Type-safe batch jobs: Batch jobs are strictly separated from scheduled/single jobs and do not support cron, delay, or repeat options.
• Adapter API extended: All core adapters now support efficient batch operations.
• Events for batch lifecycle: The queue emits batch:processing, batch:completed, and batch:failed events for batch jobs.

Handler exclusivity: A queue can handle only batch jobs or single jobs — not both. Attempting to register both handler types in the same queue will throw an error. This ensures clear and predictable processing.

Example

import { MemoryQueueAdapter, Queue } from "@vorsteh-queue/core"

type EmailPayload = { to: string; body: string }
type EmailResult = { ok: boolean }

const adapter = new MemoryQueueAdapter()
const queue = new Queue<EmailPayload, EmailResult>(adapter, {
  name: "batch-demo",
  batch: { minSize: 5, maxSize: 20, waitFor: 1000 },
})

queue.registerBatch("send-emails", async (jobs) => {
  // jobs is an array of up to 20 jobs
  await sendBulkEmails(jobs.map((j) => j.payload))
  return jobs.map(() => ({ ok: true }))
})

// Add jobs as usual
await queue.addJobs("send-emails", [
  { to: "a@example.com", body: "Hi A" },
  { to: "b@example.com", body: "Hi B" },
  // ...
])

queue.start()

Patch Changes

• 35f7171: update dependencies

@vorsteh-queue/adapter-prisma@0.3.0

Minor Changes

• b18ec50: Added support for batch processing

Patch Changes

• 35f7171: update dependencies
• Updated dependencies [66c4848]
• Updated dependencies [35f7171]
  • @vorsteh-queue/core@0.4.0

@vorsteh-queue/adapter-kysely@0.2.0

Minor Changes

• b18ec50: Added support for batch processing

Patch Changes

• 35f7171: update dependencies
• Updated dependencies [66c4848]
• Updated dependencies [35f7171]
  • @vorsteh-queue/core@0.4.0

@vorsteh-queue/adapter-drizzle@0.4.0

Minor Changes

• b18ec50: Added support for batch processing

Patch Changes

• 35f7171: update dependencies
• Updated dependencies [66c4848]
• Updated dependencies [35f7171]
  • @vorsteh-queue/core@0.4.0