bullmq - v5.64.0
    Preparing search index...

    Interface MinimalQueue

    interface MinimalQueue {
        closing: Promise<void>;
        keys: KeysMap;
        name: string;
        opts: QueueBaseOptions;
        qualifiedName: string;
        toKey: (type: string) => string;
        get client(): Promise<RedisClient>;
        get redisVersion(): string;
        emit(event: string | symbol, ...args: any[]): boolean;
        on(event: string | symbol, listener: (...args: any[]) => void): this;
        removeListener(
            event: string | symbol,
            listener: (...args: any[]) => void,
        ): this;
        trace<T>(
            spanKind: SpanKind,
            operation: string,
            destination: string,
            callback: (span?: Span, dstPropagationMetadata?: string) => T | Promise<T>,
            srcPropagationMetadata?: string,
        ): Promise<T | Promise<T>>;
        waitUntilReady(): Promise<RedisClient>;
    }

    Hierarchy (View Summary)

    Implemented by

    Index

    Properties

    closing keys name opts qualifiedName toKey

    Accessors

    client redisVersion

    Methods

    emit on removeListener trace waitUntilReady

    Properties

    closing: Promise<void>
    keys: KeysMap
    name: string
    opts: QueueBaseOptions
    qualifiedName: string
    toKey: (type: string) => string

    Accessors

    • get redisVersion(): string

      Returns the version of the Redis instance the client is connected to,

      Returns string

    Methods

    • Emits an event. Normally used by subclasses to emit events.

      Parameters

      • event: string | symbol

        The emitted event.

      • ...args: any[]

      Returns boolean

    • Parameters

      • event: string | symbol
      • listener: (...args: any[]) => void

      Returns this

    • Parameters

      • event: string | symbol
      • listener: (...args: any[]) => void

      Returns this

    • Wraps the code with telemetry and provides a span for configuration.

      Type Parameters

      • T

      Parameters

      • spanKind: SpanKind

        kind of the span: Producer, Consumer, Internal

      • operation: string

        operation name (such as add, process, etc)

      • destination: string

        destination name (normally the queue name)

      • callback: (span?: Span, dstPropagationMetadata?: string) => T | Promise<T>

        code to wrap with telemetry

      • OptionalsrcPropagationMetadata: string

      Returns Promise<T | Promise<T>>

    Settings

    Member Visibility

    On This Page

    Properties
    Accessors
    Methods