Skip to content

Commit 4c0c969

Browse files
d-csclaude
andcommitted
chore(mollifier): restore historical changeset; add buffer-extensions
Restore .changeset/mollifier-redis-worker-primitives.md to its original content (it was already on main from the Phase 1 scaffolding PR — should never have been touched during consolidation). Add .changeset/mollifier-buffer-extensions.md covering the post-scaffolding additions: idempotency lookup, snapshot mutation API, metadata CAS, watermark listing, claim primitives, ZSET-backed queue, ack grace TTL, drop-entry-TTL, and the @trigger.dev/core notice field. Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
1 parent 8e37100 commit 4c0c969

2 files changed

Lines changed: 8 additions & 3 deletions

File tree

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,6 @@
1+
---
2+
"@trigger.dev/redis-worker": minor
3+
"@trigger.dev/core": patch
4+
---
5+
6+
Mollifier buffer feature set built on top of the initial primitives: idempotency-lookup with SETNX dedup, atomic snapshot-mutation API (`mutateSnapshot` with tag/metadata/delay/cancel patches), metadata CAS for lossless concurrent updates, watermark-paginated listing, claim primitives for pre-gate idempotency, ZSET-backed per-env queue, 30s post-ack grace TTL, and drop the accept-time entry TTL (drainer is now the only removal mechanism). `@trigger.dev/core` gains an optional `notice` field on the trigger response so the SDK can surface mollifier-queued guidance to customers.
Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
11
---
2-
"@trigger.dev/redis-worker": minor
3-
"@trigger.dev/core": patch
2+
"@trigger.dev/redis-worker": patch
43
---
54

6-
Add mollifier — a Redis-backed burst buffer that absorbs trigger storms in front of `engine.trigger` and materialises them into Postgres at a controlled rate via a fair drainer.
5+
Add MollifierBuffer and MollifierDrainer primitives for burst smoothing (scaffolding only — not active without webapp wiring).

0 commit comments

Comments
 (0)