Class Bunqueue<T, R>

Simplified all-in-one Queue and Worker façade.

Type Parameters

T = unknown
R = unknown

Hierarchy

BunqueueRuntime<T, R>
- Bunqueue

Constructors

constructor

new Bunqueue<T = unknown, R = unknown>(
name: string,
options: BunqueueOptions<T, R>,
): Bunqueue<T, R>
Type Parameters
- T = unknown
- R = unknown
Parameters
- name: string
- options: BunqueueOptions<T, R>
Returns Bunqueue<T, R>
Inherited from BunqueueRuntime<T, R>.constructor
- Defined in client/bunqueue/runtime.ts:33

Properties

`Readonly`name

name: string

`Readonly`queue

queue: Queue<T>

`Readonly`worker

worker: Worker<T, R>

Methods

add

add(name: string, data: T, options?: JobOptions): Promise<Job<T>>
Parameters
- name: string
- data: T
- Optionaloptions: JobOptions
Returns Promise<Job<T>>
- Defined in client/bunqueue.ts:25

addBulk

addBulk(jobs: { data: T; name: string; opts?: JobOptions }[]): Promise<Job<T>[]>
Parameters
- jobs: { data: T; name: string; opts?: JobOptions }[]
Returns Promise<Job<T>[]>
- Defined in client/bunqueue.ts:29

cancel

cancel(jobId: string, gracePeriodMs?: number): void
Parameters
- jobId: string
- gracePeriodMs: number = 0
Returns void
- Defined in client/bunqueue.ts:92

close

close(force?: boolean): Promise<void>
Parameters
- force: boolean = false
Returns Promise<void>
- Defined in client/bunqueue.ts:234

count

count(): number
Returns number
- Defined in client/bunqueue.ts:50

countAsync

countAsync(): Promise<number>
Returns Promise<number>
- Defined in client/bunqueue.ts:54

cron

cron(
    id: string,
    pattern: string,
    data?: T,
    options?: { jobOpts?: JobOptions; limit?: number; timezone?: string },
): Promise<SchedulerInfo | null>
Parameters
- id: string
- pattern: string
- Optionaldata: T
- Optionaloptions: { jobOpts?: JobOptions; limit?: number; timezone?: string }
Returns Promise<SchedulerInfo | null>
- Defined in client/bunqueue.ts:58

every

every(
    id: string,
    intervalMs: number,
    data?: T,
    options?: { jobOpts?: JobOptions; limit?: number },
): Promise<SchedulerInfo | null>
Parameters
- id: string
- intervalMs: number
- Optionaldata: T
- Optionaloptions: { jobOpts?: JobOptions; limit?: number }
Returns Promise<SchedulerInfo | null>
- Defined in client/bunqueue.ts:71

getCircuitState

getCircuitState(): CircuitState
Returns CircuitState
- Defined in client/bunqueue.ts:104

getDlq

getDlq(filter?: DlqFilter): DlqEntry<T>[]
Parameters
- Optionalfilter: DlqFilter
Returns DlqEntry<T>[]
- Defined in client/bunqueue.ts:141

getDlqAsync

getDlqAsync(filter?: DlqFilter): Promise<DlqEntry<T>[]>
Parameters
- Optionalfilter: DlqFilter
Returns Promise<DlqEntry<T>[]>
- Defined in client/bunqueue.ts:145

getDlqConfig

getDlqConfig(): DlqConfig
Returns DlqConfig
- Defined in client/bunqueue.ts:133

getDlqConfigAsync

getDlqConfigAsync(): Promise<DlqConfig>
Returns Promise<DlqConfig>
- Defined in client/bunqueue.ts:137

getDlqStats

getDlqStats(): DlqStats
Returns DlqStats
- Defined in client/bunqueue.ts:149

getDlqStatsAsync

getDlqStatsAsync(): Promise<DlqStats>
Returns Promise<DlqStats>
- Defined in client/bunqueue.ts:153

getJob

getJob(id: string): Promise<Job<T> | null>
Parameters
- id: string
Returns Promise<Job<T> | null>
- Defined in client/bunqueue.ts:38

getJobCounts

getJobCounts(): JobCounts | Promise<JobCounts>
Returns JobCounts | Promise<JobCounts>
- Defined in client/bunqueue.ts:42

getJobCountsAsync

getJobCountsAsync(): Promise<JobCounts>
Returns Promise<JobCounts>
- Defined in client/bunqueue.ts:46

getSignal

getSignal(jobId: string): AbortSignal | null
Parameters
- jobId: string
Returns AbortSignal | null
- Defined in client/bunqueue.ts:100

isCancelled

isCancelled(jobId: string): boolean
Parameters
- jobId: string
Returns boolean
- Defined in client/bunqueue.ts:96

isClosed

isClosed(): boolean
Returns boolean
- Defined in client/bunqueue.ts:251

isPaused

isPaused(): boolean
Returns boolean
- Defined in client/bunqueue.ts:247

isRunning

isRunning(): boolean
Returns boolean
- Defined in client/bunqueue.ts:243

listCrons

listCrons(): Promise<SchedulerInfo[]>
Returns Promise<SchedulerInfo[]>
- Defined in client/bunqueue.ts:88

off

off(event: any, listener: (...args: any[]) => void): this
Parameters
- event: any
- listener: (...args: any[]) => void
Returns this
- Defined in client/bunqueue.ts:209

on

on(event: "drained" | "ready" | "closed", listener: () => void): this
Parameters
- event: "drained" | "ready" | "closed"
- listener: () => void
Returns this
- Defined in client/bunqueue.ts:189
on(event: "active", listener: (job: Job<T>) => void): this
Parameters
- event: "active"
- listener: (job: Job<T>) => void
Returns this
- Defined in client/bunqueue.ts:190
on(event: "completed", listener: (job: Job<T>, result: R) => void): this
Parameters
- event: "completed"
- listener: (job: Job<T>, result: R) => void
Returns this
- Defined in client/bunqueue.ts:191
on(event: "failed", listener: (job: Job<T>, error: Error) => void): this
Parameters
- event: "failed"
- listener: (job: Job<T>, error: Error) => void
Returns this
- Defined in client/bunqueue.ts:192
on(
event: "progress",
listener: (job: Job<T> | null, progress: number) => void,
): this
Parameters
- event: "progress"
- listener: (job: Job<T> | null, progress: number) => void
Returns this
- Defined in client/bunqueue.ts:193
on(event: "stalled", listener: (jobId: string, reason: string) => void): this
Parameters
- event: "stalled"
- listener: (jobId: string, reason: string) => void
Returns this
- Defined in client/bunqueue.ts:194
on(event: "error", listener: (error: Error) => void): this
Parameters
- event: "error"
- listener: (error: Error) => void
Returns this
- Defined in client/bunqueue.ts:195

once

once(event: "drained" | "ready" | "closed", listener: () => void): this
Parameters
- event: "drained" | "ready" | "closed"
- listener: () => void
Returns this
- Defined in client/bunqueue.ts:201
once(event: "completed", listener: (job: Job<T>, result: R) => void): this
Parameters
- event: "completed"
- listener: (job: Job<T>, result: R) => void
Returns this
- Defined in client/bunqueue.ts:202
once(event: "failed", listener: (job: Job<T>, error: Error) => void): this
Parameters
- event: "failed"
- listener: (job: Job<T>, error: Error) => void
Returns this
- Defined in client/bunqueue.ts:203

pause

pause(): void
Returns void
- Defined in client/bunqueue.ts:214

pauseAsync

pauseAsync(): Promise<void>
Returns Promise<void>
- Defined in client/bunqueue.ts:224

purgeDlq

purgeDlq(): number
Returns number
- Defined in client/bunqueue.ts:165

purgeDlqAsync

purgeDlqAsync(): Promise<number>
Returns Promise<number>
- Defined in client/bunqueue.ts:169

removeCron

removeCron(id: string): Promise<boolean>
Parameters
- id: string
Returns Promise<boolean>
- Defined in client/bunqueue.ts:84

removeGlobalRateLimit

removeGlobalRateLimit(): void
Returns void
- Defined in client/bunqueue.ts:181

removeGlobalRateLimitAsync

removeGlobalRateLimitAsync(): Promise<void>
Returns Promise<void>
- Defined in client/bunqueue.ts:185

resetCircuit

resetCircuit(): void
Returns void
- Defined in client/bunqueue.ts:108

resume

resume(): void
Returns void
- Defined in client/bunqueue.ts:219

resumeAsync

resumeAsync(): Promise<void>
Returns Promise<void>
- Defined in client/bunqueue.ts:229

retryDlq

retryDlq(id?: string): number
Parameters
- Optionalid: string
Returns number
- Defined in client/bunqueue.ts:157

retryDlqAsync

retryDlqAsync(id?: string): Promise<number>
Parameters
- Optionalid: string
Returns Promise<number>
- Defined in client/bunqueue.ts:161

setDefaultTtl

setDefaultTtl(ttlMs: number): void
Parameters
- ttlMs: number
Returns void
- Defined in client/bunqueue.ts:117

setDlqConfig

setDlqConfig(config: Partial<DlqConfig>): void
Parameters
- config: Partial<DlqConfig>
Returns void
- Defined in client/bunqueue.ts:125

setDlqConfigAsync

setDlqConfigAsync(config: Partial<DlqConfig>): Promise<void>
Parameters
- config: Partial<DlqConfig>
Returns Promise<void>
- Defined in client/bunqueue.ts:129

setGlobalRateLimit

setGlobalRateLimit(max: number, duration?: number): void
Parameters
- max: number
- Optionalduration: number
Returns void
- Defined in client/bunqueue.ts:173

setGlobalRateLimitAsync

setGlobalRateLimitAsync(max: number, duration?: number): Promise<void>
Parameters
- max: number
- Optionalduration: number
Returns Promise<void>
- Defined in client/bunqueue.ts:177

setNameTtl

setNameTtl(name: string, ttlMs: number): void
Parameters
- name: string
- ttlMs: number
Returns void
- Defined in client/bunqueue.ts:121

trigger

trigger(rule: TriggerRule<T>): this
Parameters
- rule: TriggerRule<T>
Returns this
- Defined in client/bunqueue.ts:112

use

use(middleware: BunqueueMiddleware<T, R>): this
Parameters
- middleware: BunqueueMiddleware<T, R>
Returns this
Inherited from BunqueueRuntime.use
- Defined in client/bunqueue/runtime.ts:166