diff options
| author | Mohamed Bassem <me@mbassem.com> | 2025-11-24 01:23:06 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2025-11-24 01:23:06 +0000 |
| commit | 54268759492df88644e4279fdcc600214f922f43 (patch) | |
| tree | 610cb784662ca2c7513f67aa7a74f3a8d3e40b3f /packages/shared/queueing.ts | |
| parent | 38842f77e549fd0946e43a40c65abe0f196c3f04 (diff) | |
| download | karakeep-54268759492df88644e4279fdcc600214f922f43.tar.zst | |
feat: Introduce groupId in restate queue (#2168)
* feat: Introduce groupId in restate queue
* add group ids to the interface
* use last served timestamp
Diffstat (limited to 'packages/shared/queueing.ts')
| -rw-r--r-- | packages/shared/queueing.ts | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/packages/shared/queueing.ts b/packages/shared/queueing.ts index ed6759dd..0dd6ed6b 100644 --- a/packages/shared/queueing.ts +++ b/packages/shared/queueing.ts @@ -6,6 +6,7 @@ export interface EnqueueOptions { idempotencyKey?: string; priority?: number; delayMs?: number; + groupId?: string; } export interface QueueOptions { |