@vasto-queue/mysql-store

MySQL storage adapter for Vasto.

Uses mysql2 with transactional dequeue and FOR UPDATE SKIP LOCKED for concurrent safe leasing on MySQL 8+.

Installation

npm install @vasto-queue/mysql-store mysql2

Usage

import { MySqlStore } from '@vasto-queue/mysql-store';

const store = new MySqlStore({
	pool: {
		uri: 'mysql://user:password@localhost:3306/mydb',
		connectionLimit: 10,
	},
});

await store.migrate();

Features

• Queue lifecycle support (enqueue, dequeue, ack, fail, extendLease)
• Deferred jobs and promotion support
• Dead-letter queue and retry support
• Progress tracking
• Completed jobs archive with retention controls