Skip to content

Examples

All examples are self-contained and runnable. Each one demonstrates a single integration or pattern.

Source: examples/

How to connect Queuert to your database using different ORMs and drivers.

Example ORM / Driver
state-postgres-kysely Kysely
state-postgres-knex Knex
state-postgres-drizzle Drizzle ORM
state-postgres-prisma Prisma
state-postgres-pg pg (node-postgres)
state-postgres-postgres-js postgres.js
state-postgres-multi-worker Multiple workers sharing one database
Example ORM / Driver
state-sqlite-node node:sqlite
state-sqlite-bun bun:sqlite
state-sqlite-better-sqlite3 better-sqlite3
state-sqlite-kysely Kysely
state-sqlite-knex Knex
state-sqlite-drizzle Drizzle ORM
state-sqlite-prisma Prisma

How to set up real-time job notifications between client and workers.

Example Transport
notify-redis-redis Redis (node-redis)
notify-redis-ioredis Redis (ioredis)
notify-redis-cluster-node-redis Redis Cluster (node-redis)
notify-redis-cluster-ioredis Redis Cluster (ioredis)
notify-nats-nats NATS
notify-postgres-pg PostgreSQL LISTEN/NOTIFY (pg)
notify-postgres-postgres-js PostgreSQL LISTEN/NOTIFY (postgres.js)

Chain patterns, error handling, scheduling, and other core features.

Example What it demonstrates
showcase-chain-patterns Linear, branched, looped, and go-to chain execution
showcase-error-handling Discriminated unions, compensation, rescheduling
showcase-error-recovery Engine-level recovery: savepoints, post-complete errors, staged retries
showcase-scheduling Delayed and time-scheduled jobs
showcase-blockers Cross-chain job dependencies
showcase-chain-awaiting Awaiting chain completion programmatically
showcase-chain-deletion Deleting chains
showcase-processing-modes Atomic vs staged processing modes
showcase-queries Querying jobs and chains
showcase-timeouts Job and chain timeouts
showcase-slices Feature slices with merged job types and processors
showcase-cleanup Automatic cleanup of completed chains
showcase-workerless Running without a worker (polling only)
showcase-multiworker-prioritization Priority tiers via specialized workers; cross-worker chain handoff
showcase-middleware Attempt middleware: wrapHandler, wrapPrepare, wrapStep, wrapComplete with typed ctx
showcase-signals Abort signal patterns
Example Logger
log-console Built-in console logger
log-pino Pino
log-winston Winston

Input/output validation with different schema libraries.

Example Library
validation-zod Zod
validation-arktype ArkType
validation-valibot Valibot
validation-typebox TypeBox
Example What it demonstrates
observability-otel OpenTelemetry tracing and metrics
dashboard Web dashboard UI with SQLite