Class GuildTaskQueue

Serialized per-guild asynchronous task queue. Guarantees FIFO execution of join reconciliation tasks per guild to prevent REST rate limits and race conditions during high-volume join storms.

Index

Constructors

Accessors

Methods

clear enqueue getQueueDepth

Constructors

constructor

new GuildTaskQueue(): GuildTaskQueue
Returns GuildTaskQueue

Accessors

activeGuilds

get activeGuilds(): number
Returns the number of guilds currently running or waiting on queued tasks.

Returns number
- Defined in src/queue.ts:51

Methods

clear

clear(): void
Clear all queues.

Returns void
- Defined in src/queue.ts:65

enqueue

enqueue<T>(guildId: string, task: () => Promise<T>): Promise<T>
Enqueue a task for a specific guild. Tasks for the same guild are executed sequentially, while tasks for different guilds run concurrently.
Type Parameters
- T
Parameters
- guildId: string
  The guild identifier.
- task: () => Promise<T>
  The async callback to execute.
Returns Promise<T>
The resolved value of the task.
- Defined in src/queue.ts:18

getQueueDepth

getQueueDepth(guildId: string): number
Get the number of pending tasks for a specific guild.
Parameters
- guildId: string
Returns number
- Defined in src/queue.ts:58