Examples
All examples are self-contained and runnable. Each one demonstrates a single integration or pattern.
Source: examples/
State Adapters
Section titled “State Adapters”How to connect Queuert to your database using different ORMs and drivers.
PostgreSQL
Section titled “PostgreSQL”| Example | ORM / Driver |
|---|---|
| state-postgres-kysely | Kysely |
| 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 |
SQLite
Section titled “SQLite”| Example | ORM / Driver |
|---|---|
| state-sqlite-node | node:sqlite |
| state-sqlite-better-sqlite3 | better-sqlite3 |
| state-sqlite-kysely | Kysely |
| state-sqlite-drizzle | Drizzle ORM |
| state-sqlite-prisma | Prisma |
Notify Adapters
Section titled “Notify Adapters”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) |
Patterns & Features
Section titled “Patterns & Features”Job 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 job 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 registries and processors |
| showcase-cleanup | Automatic cleanup of completed job chains |
| showcase-workerless | Running without a worker (polling only) |
| showcase-multiworker-prioritization | Priority tiers via specialized workers; cross-worker chain handoff |
Logging
Section titled “Logging”| Example | Logger |
|---|---|
| log-console | Built-in console logger |
| log-pino | Pino |
| log-winston | Winston |
Validation
Section titled “Validation”Input/output validation with different schema libraries.
| Example | Library |
|---|---|
| validation-zod | Zod |
| validation-arktype | ArkType |
| validation-valibot | Valibot |
| validation-typebox | TypeBox |
Observability & Dashboard
Section titled “Observability & Dashboard”| Example | What it demonstrates |
|---|---|
| observability-otel | OpenTelemetry tracing and metrics |
| dashboard | Web dashboard UI with SQLite |