Extend & integrate

Hook into the task lifecycle, watch what it does, and wire the Node.js SDK into the rest of your stack.

Everything that attaches to flexiq from the outside: the extension points that run inside the task lifecycle, the signals they emit, and the frameworks and vendors on the other end of those signals.

Extension points

Lifecycle events and middleware are the extension points for pushing any of these signals to an external system.

EventsSubscribe to queue and worker lifecycle events Per-Task MiddlewareWrap task execution with before/after/error hooks WebhooksPush signed notifications to external services Pluggable SerializersCustom payload serialization — msgpack, encryption

Watch it run

See what the queue is doing — counts, per-task latency, job progress, live workers — and emit structured logs, all from the Queue handle with no extra service.

Monitoring & hooksQueue health, worker hooks, and what to alert on Structured task loggingPer-task log capture, correlation, and where the lines go Structured notesAttach progress and diagnostics to a running job Testing tasksRun tasks inline, assert on outcomes, and keep suites fast

Integrations are optional helpers that ship alongside the core SDK but are not exported from the main @byteveda/flexiq barrel. Each lives behind its own @byteveda/flexiq/contrib/* subpath and requires you to install its peer dependency.

bash

# Only install what you use.
pnpm add @opentelemetry/api               # @byteveda/flexiq/contrib/otel
pnpm add prom-client                      # @byteveda/flexiq/contrib/prometheus
pnpm add @sentry/node                     # @byteveda/flexiq/contrib/sentry
pnpm add express                          # @byteveda/flexiq/contrib/express
pnpm add fastify                          # @byteveda/flexiq/contrib/fastify
pnpm add @nestjs/common reflect-metadata  # @byteveda/flexiq/contrib/nest

Integrations never auto-initialize. Nothing runs until you call the export and register it with your queue or framework. If a peer dependency is missing, importing its subpath fails with a standard module-not-found error.

OpenTelemetryone span per execution attempt.Prometheusexecution metrics + polled depth gauges.Sentrycapture the original exception on dead-letter.ExpressREST router + dashboard mount.FastifyREST + dashboard plugins.NestJSinjectable FlexiQService.