dataqueue-core

Create type-safe job queues with PayloadMap and handlers in TypeScript.

1|1|Updated Jan 5, 2026
One-click install
npx skills add https://github.com/hyperjumptech/mediapulse --skill dataqueue-core-hyperjumptech
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: dataqueue-core
Source: https://github.com/hyperjumptech/mediapulse/tree/main/.cursor/skills/dataqueue-core
Command: npx skills add https://github.com/hyperjumptech/mediapulse --skill dataqueue-core-hyperjumptech

SYSTEM DOCUMENTATION & REQUIREMENTS

What problem does it solve?

This skill solves the challenge of building reliable, type-safe data queues by enforcing a PayloadMap-driven contract and strongly typed job handlers.

Core Features & Use Cases

  • Type-safe PayloadMap and JobHandlers ensure completeness and correct typing for every job type.
  • Singleton queue initialization with pluggable backends (PostgreSQL or Redis) for predictable resource management.
  • Comprehensive job lifecycle: add jobs (including batch inserts), per-job options (priority, runAt, tags, idempotencyKey), dependencies, retries, and dead-letter handling.
  • Serverless or long-running processing patterns using a processor and optional supervisor for maintenance.

Quick Start

Initialize a queue by defining your PayloadMap and handlers, then start a processor to begin processing jobs.

Frequently Asked Questions about dataqueue-core

High-intent search queries and answers about installing and using this skill.

FAQPage Schema
How do I enforce type safety for job payloads in TypeScript asynchronous queues?

Type-safe job payloads in TypeScript queues are enforced by defining a PayloadMap and strongly typed JobHandlers, ensuring correct typing and completeness for every job type to prevent runtime errors.

Can I use PostgreSQL and Redis for backend job processing in TypeScript?

PostgreSQL and Redis can be used for backend job processing through pluggable queue initialization, enabling predictable resource management and reliable transactional job creation within TypeScript services.

How do I handle retries, dependencies, and dead-lettering for batch jobs?

Batch jobs support comprehensive lifecycle management including per-job options like priority and runAt, alongside job dependencies, automated retries, and dead-letter handling for failed asynchronous tasks.

What is the best way to process queued jobs in a serverless environment?

Serverless job processing is handled using a dedicated processor and an optional supervisor for maintenance, supporting both serverless functions and long-running processing patterns for scalable queue execution.

How do I set idempotency keys and priority for queued tasks?

Idempotency keys and priority are configured by applying per-job options when adding jobs to the queue, allowing granular control over task execution order and preventing duplicate processing.