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.

ExampleORM / DriverSource
state-postgres-kyselyKyselysource
state-postgres-drizzleDrizzle ORMsource
state-postgres-prismaPrismasource
state-postgres-pgpg (node-postgres)source
state-postgres-postgres-jspostgres.jssource
state-postgres-multi-workerMultiple workers sharing one databasesource
ExampleORM / DriverSource
state-sqlite-better-sqlite3better-sqlite3source
state-sqlite-kyselyKyselysource
state-sqlite-drizzleDrizzle ORMsource
state-sqlite-prismaPrismasource
state-sqlite-sqlite3sqlite3 (async)source

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

ExampleTransportSource
notify-redis-redisRedis (node-redis)source
notify-redis-ioredisRedis (ioredis)source
notify-nats-natsNATSsource
notify-postgres-pgPostgreSQL LISTEN/NOTIFY (pg)source
notify-postgres-postgres-jsPostgreSQL LISTEN/NOTIFY (postgres.js)source

Job chain patterns, error handling, scheduling, and other core features.

ExampleWhat it demonstratesSource
showcase-chain-patternsLinear, branched, looped, and go-to chain executionsource
showcase-error-handlingDiscriminated unions, compensation, reschedulingsource
showcase-schedulingDelayed and time-scheduled jobssource
showcase-blockersCross-chain job dependenciessource
showcase-chain-awaitingAwaiting chain completion programmaticallysource
showcase-chain-deletionDeleting job chainssource
showcase-processing-modesAtomic vs staged processing modessource
showcase-queriesQuerying jobs and chainssource
showcase-timeoutsJob and chain timeoutssource
showcase-slicesFeature slices with merged registries and processorssource
showcase-workerlessRunning without a worker (polling only)source
ExampleLoggerSource
log-consoleBuilt-in console loggersource
log-pinoPinosource
log-winstonWinstonsource

Input/output validation with different schema libraries.

ExampleLibrarySource
validation-zodZodsource
validation-arktypeArkTypesource
validation-valibotValibotsource
validation-typeboxTypeBoxsource
ExampleWhat it demonstratesSource
observability-otelOpenTelemetry tracing and metricssource
dashboardWeb dashboard UI with SQLitesource
ExampleWhat it measuresSource
benchmark-memory-footprintMemory usage under loadsource