Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
44 changes: 0 additions & 44 deletions .changeset/funny-cobras-sneeze.md

This file was deleted.

5 changes: 0 additions & 5 deletions .changeset/loose-parrots-glow copy 2.md

This file was deleted.

5 changes: 0 additions & 5 deletions .changeset/loose-parrots-glow copy.md

This file was deleted.

8 changes: 0 additions & 8 deletions .changeset/loose-parrots-glow.md

This file was deleted.

9 changes: 9 additions & 0 deletions packages/adapter-drizzle/CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,5 +1,14 @@
# @vorsteh-queue/adapter-drizzle

## 0.3.2

### Patch Changes

- 4414f87: Add `PostgresQueueAdapter` as alias to `PostgresDrizzleQueueAdapter`
- 73cdaf2: update dependencies
- Updated dependencies [73cdaf2]
- @vorsteh-queue/[email protected]

## 0.3.1

### Patch Changes
Expand Down
2 changes: 1 addition & 1 deletion packages/adapter-drizzle/package.json
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"name": "@vorsteh-queue/adapter-drizzle",
"version": "0.3.1",
"version": "0.3.2",
"description": "Drizzle ORM adapter for Vorsteh Queue with PostgreSQL support",
"keywords": [
"queue",
Expand Down
50 changes: 50 additions & 0 deletions packages/adapter-kysely/CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,50 @@
# @vorsteh-queue/adapter-kysely

## 0.1.0

### Minor Changes

- 73cdaf2: Add Kysely ORM adapter for PostgreSQL with type-safe database operations

**Features:**
- `PostgresQueueAdapter`: PostgreSQL support using Kysely ORM
- Raw SQL with `SKIP LOCKED` for race condition prevention
- UTC-first design with proper timezone handling
- Database schema uses UTC defaults: `timezone('utc', now())` for PostgreSQL
- All timestamps explicitly stored as UTC for consistent behavior

**Usage:**

```typescript
import { Kysely, PostgresDialect } from "kysely"
import { Pool } from "pg"

import { PostgresQueueAdapter } from "@vorsteh-queue/adapter-kysely"
import { Queue } from "@vorsteh-queue/core"

const db = new Kysely({
dialect: new PostgresDialect({
pool: new Pool({ connectionString: "postgresql://..." }),
}),
})

const adapter = new PostgresQueueAdapter(db)
const queue = new Queue(adapter, { name: "my-queue" })

// Register job handlers
queue.register("send-email", async (payload: { to: string }) => {
// Send email logic
return { sent: true }
})

// Add jobs
await queue.add("send-email", { to: "[email protected]" })

// Start processing
queue.start()
```

### Patch Changes

- Updated dependencies [73cdaf2]
- @vorsteh-queue/[email protected]
2 changes: 1 addition & 1 deletion packages/adapter-kysely/package.json
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"name": "@vorsteh-queue/adapter-kysely",
"version": "0.0.0",
"version": "0.1.0",
"description": "Kysely adapter for Vorsteh Queue with PostgreSQL support",
"keywords": [
"queue",
Expand Down
9 changes: 9 additions & 0 deletions packages/adapter-prisma/CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,5 +1,14 @@
# @vorsteh-queue/adapter-prisma

## 0.2.2

### Patch Changes

- 4414f87: Add `PostgresQueueAdapter` as alias to `PostgresPrismaQueueAdapter`
- 73cdaf2: update dependencies
- Updated dependencies [73cdaf2]
- @vorsteh-queue/[email protected]

## 0.2.1

### Patch Changes
Expand Down
2 changes: 1 addition & 1 deletion packages/adapter-prisma/package.json
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"name": "@vorsteh-queue/adapter-prisma",
"version": "0.2.1",
"version": "0.2.2",
"description": "Prisma ORM adapter for Vorsteh Queue with PostgreSQL support",
"keywords": [
"queue",
Expand Down
6 changes: 6 additions & 0 deletions packages/core/CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,5 +1,11 @@
# @vorsteh-queue/core

## 0.3.2

### Patch Changes

- 73cdaf2: update dependencies

## 0.3.1

### Patch Changes
Expand Down
2 changes: 1 addition & 1 deletion packages/core/package.json
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"name": "@vorsteh-queue/core",
"version": "0.3.1",
"version": "0.3.2",
"description": "Core queue engine for Vorsteh Queue with TypeScript support, job scheduling, and event system",
"keywords": [
"queue",
Expand Down
6 changes: 6 additions & 0 deletions packages/create-vorsteh-queue/CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,5 +1,11 @@
# create-vorsteh-queue

## 0.1.2

### Patch Changes

- 73cdaf2: update dependencies

## 0.1.1

### Patch Changes
Expand Down
2 changes: 1 addition & 1 deletion packages/create-vorsteh-queue/package.json
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"name": "create-vorsteh-queue",
"version": "0.1.1",
"version": "0.1.2",
"description": "Create Vorsteh Queue applications with one command",
"keywords": [
"vorsteh-queue",
Expand Down
Loading