Class EventQueue<S, E>

Type Parameters

S extends Record<string, any>
E extends Events<S> | RegExp = Events<S>

Index

Constructors

constructor

new EventQueue<
    S extends Record<string, any>,
    E extends string | number | symbol | RegExp = keyof S,
>(
    opts: QueueOpts & {
        event: RegExp | E;
        observer?: ObserverEngine<S>;
        process: (data: EventData<S, E>) => Promise<void>;
    },
): EventQueue<S, E>
Type Parameters
- S extends Record<string, any>
- E extends string | number | symbol | RegExp = keyof S
Parameters
- opts: QueueOpts & {
      event: RegExp | E;
      observer?: ObserverEngine<S>;
      process: (data: EventData<S, E>) => Promise<void>;
  }
Returns EventQueue<S, E>
- Defined in packages/observer/src/queue/queue.ts:150

Accessors

isDraining

get isDraining(): boolean
Whether the queue is draining

Returns boolean
- Defined in packages/observer/src/queue/queue.ts:760

isIdle

get isIdle(): boolean
Whether the queue is idle

Returns boolean
- Defined in packages/observer/src/queue/queue.ts:730

isPaused

get isPaused(): boolean
Whether the queue is paused

Returns boolean
- Defined in packages/observer/src/queue/queue.ts:745

isRunning

get isRunning(): boolean
Whether the queue is running

Returns boolean
- Defined in packages/observer/src/queue/queue.ts:738

isStopped

get isStopped(): boolean
Whether the queue is stopped

Returns boolean
- Defined in packages/observer/src/queue/queue.ts:752

isWaiting

get isWaiting(): boolean
Whether the queue is waiting for the the

Returns boolean
- Defined in packages/observer/src/queue/queue.ts:723

name

get name(): string
The name of the queue

Returns string
- Defined in packages/observer/src/queue/queue.ts:715

pending

get pending(): number
The number of items in the queue

Returns number
- Defined in packages/observer/src/queue/queue.ts:774

snapshot

get snapshot(): {
    activeRunners: number;
    isDraining: boolean;
    isEmpty: boolean;
    isIdle: boolean;
    isPaused: boolean;
    isRunning: boolean;
    isStopped: boolean;
    isWaiting: boolean;
    name: string;
    pending: number;
    rateLimiter: {
        averageWaitTime: number;
        capacity: number;
        createdAt: number;
        currentTokens: number;
        refillIntervalMs: number;
        rejectedRequests: number;
        rejectionRate: number;
        successfulRequests: number;
        totalRequests: number;
        totalWaitTime: number;
        uptime: number;
        waitCount: number;
    };
    runningNodes: Set<`${number}-${number}`>;
    state: QueueState;
    stats: {
        avgProcessingTime: number;
        error: number;
        processed: number;
        processing: number;
        rejected: number;
        success: number;
    };
}
Returns {
    activeRunners: number;
    isDraining: boolean;
    isEmpty: boolean;
    isIdle: boolean;
    isPaused: boolean;
    isRunning: boolean;
    isStopped: boolean;
    isWaiting: boolean;
    name: string;
    pending: number;
    rateLimiter: {
        averageWaitTime: number;
        capacity: number;
        createdAt: number;
        currentTokens: number;
        refillIntervalMs: number;
        rejectedRequests: number;
        rejectionRate: number;
        successfulRequests: number;
        totalRequests: number;
        totalWaitTime: number;
        uptime: number;
        waitCount: number;
    };
    runningNodes: Set<`${number}-${number}`>;
    state: QueueState;
    stats: {
        avgProcessingTime: number;
        error: number;
        processed: number;
        processing: number;
        rejected: number;
        success: number;
    };
}
- Defined in packages/observer/src/queue/queue.ts:787

state

get state(): QueueState
The current state of the queue

Returns QueueState
- Defined in packages/observer/src/queue/queue.ts:767

stats

get stats(): {
    avgProcessingTime: number;
    error: number;
    processed: number;
    processing: number;
    rejected: number;
    success: number;
}
The stats of the queue

Returns {
    avgProcessingTime: number;
    error: number;
    processed: number;
    processing: number;
    rejected: number;
    success: number;
}
- Defined in packages/observer/src/queue/queue.ts:782

Methods

add

add(data: EventData<S, E>, priority?: number): boolean
Emit an event to the observer, which then gets picked up by the queue and processed.
Parameters
- data: EventData<S, E>
  The data to add to the queue
- Optionalpriority: number
  The priority of the data
Returns boolean
Note
If priority is provided, it will be used to determine the order of the data in the queue. The higher the priority, the sooner the data will be processed.

Note
If priority is not provided, the data will be added to the queue with a priority of 0.
- Defined in packages/observer/src/queue/queue.ts:628

debug

debug(on?: boolean | "info" | "verbose"): void
Parameters
- on: boolean | "info" | "verbose" = false
Returns void
- Defined in packages/observer/src/queue/queue.ts:653

flush

flush(limit?: number): Promise<number>
Executes limit items in the queue and then emits a flush event. Returns the number of items processed.
Parameters
- limit: number = Infinity
Returns Promise<number>
- Defined in packages/observer/src/queue/queue.ts:593

off

off<K extends keyof QueueEvents<S, E>>(event: K, listener?: Function): void
Type Parameters
- K extends keyof QueueEvents<S, E>
Parameters
- event: K
- Optionallistener: Function
Returns void
- Defined in packages/observer/src/queue/queue.ts:703

on

on<K extends keyof QueueEvents<S, E>>(
event: K,
listener: (payload: InternalQueueEvent<QueueEvents<S, E>[K]>) => void,
): ObserverEngine.Cleanup
Type Parameters
- K extends keyof QueueEvents<S, E>
Parameters
- event: K
- listener: (payload: InternalQueueEvent<QueueEvents<S, E>[K]>) => void
Returns ObserverEngine.Cleanup
- Defined in packages/observer/src/queue/queue.ts:663
on<K extends keyof QueueEvents<S, E>>(
event: K,
): EventGenerator<QueueEvents<S, E>, K>
Type Parameters
- K extends keyof QueueEvents<S, E>
Parameters
- event: K
Returns EventGenerator<QueueEvents<S, E>, K>
- Defined in packages/observer/src/queue/queue.ts:668

once

once<K extends keyof QueueEvents<S, E>>(
event: K,
): EventPromise<InternalQueueEvent<QueueEvents<S, E>[K]>>
Type Parameters
- K extends keyof QueueEvents<S, E>
Parameters
- event: K
Returns EventPromise<InternalQueueEvent<QueueEvents<S, E>[K]>>
- Defined in packages/observer/src/queue/queue.ts:683
once<K extends keyof QueueEvents<S, E>>(
event: K,
listener: (payload: InternalQueueEvent<QueueEvents<S, E>[K]>) => void,
): ObserverEngine.Cleanup
Type Parameters
- K extends keyof QueueEvents<S, E>
Parameters
- event: K
- listener: (payload: InternalQueueEvent<QueueEvents<S, E>[K]>) => void
Returns ObserverEngine.Cleanup
- Defined in packages/observer/src/queue/queue.ts:687

pause

pause(): Promise<void> | undefined
Pause the queue

Returns Promise<void> | undefined
- Defined in packages/observer/src/queue/queue.ts:492

purge

purge(): number
Clears the queue and emits a purge event. Returns the number of items purged.

Returns number
- Defined in packages/observer/src/queue/queue.ts:606

resume

resume(): Promise<void> | undefined
Resume the queue

Returns Promise<void> | undefined
- Defined in packages/observer/src/queue/queue.ts:505

shutdown

shutdown(force?: boolean): Promise<number>
Empty and process all items in the queue and then stop the queue. Returns the number of items processed.
Parameters
- force: boolean = false
Returns Promise<number>
- Defined in packages/observer/src/queue/queue.ts:552

start

start(): Promise<void> | undefined
Start the queue if it is not already started

Returns Promise<void> | undefined
- Defined in packages/observer/src/queue/queue.ts:464

stop

stop(): void
Stop the queue

Returns void
- Defined in packages/observer/src/queue/queue.ts:480

Class EventQueue<S, E>

Type Parameters

Index

Constructors

Accessors

Methods

Constructors

constructor

Type Parameters

Parameters

Returns EventQueue<S, E>

Accessors

isDraining

Returns boolean

isIdle

Returns boolean

isPaused

Returns boolean

isRunning

Returns boolean

isStopped

Returns boolean

isWaiting

Returns boolean

name

Returns string

pending

Returns number

snapshot

state

Returns QueueState

stats

Returns { avgProcessingTime: number; error: number; processed: number; processing: number; rejected: number; success: number;}

Methods

add

Parameters

Returns boolean

Note

Note

debug

Parameters

Returns void

flush

Parameters

Returns Promise<number>

off

Type Parameters

Parameters

Returns void

on

Type Parameters

Parameters

Returns ObserverEngine.Cleanup

Type Parameters

Parameters

Returns EventGenerator<QueueEvents<S, E>, K>

once

Type Parameters

Parameters

Returns EventPromise<InternalQueueEvent<QueueEvents<S, E>[K]>>

Type Parameters

Parameters

Returns ObserverEngine.Cleanup

pause

Returns Promise<void> | undefined

purge

Returns number

resume

Returns Promise<void> | undefined

shutdown

Parameters

Returns Promise<number>

start

Returns Promise<void> | undefined

stop

Returns void

Settings

On This Page

Returns {
avgProcessingTime: number;
error: number;
processed: number;
processing: number;
rejected: number;
success: number;
}