@taskforcesh/bullmq-pro - v7.35.2
    Preparing search index...

    Class QueuePro<DataType, ReturnType, NameType>

    Type Parameters

    • DataType = any
    • ReturnType = any
    • NameType extends string = string

    Hierarchy

    Index

    Constructors

    Methods

    • Cleans all the jobs that are part of a group.

      Parameters

      • groupId: string | number

      Returns Promise<void>

    • Gets the count of jobs inside a given group id.

      Parameters

      • groupId: string | number

      Returns Promise<number>

    • Get the group ids with jobs current jobs in them.

      TODO: Support group id filtering.

      Parameters

      • start: number = 0
      • end: number = -1

      Returns Promise<{ id: string; status: GroupStatus }[]>

    • Gets all the groups that are in a particular status.

      Parameters

      • status: GroupStatus

        GroupStatus so we can filter by status

      • start: number = 0

        start index, used for pagination.

      • end: number = -1

        end index, used for pagination.

      Returns Promise<{ count: number; id: string }[]>

      an array of objects with the group id and status.

    • Get the total number of groups with jobs in them.

      Returns Promise<number>

    • Get the total number of groups with jobs in them, in their different statuses.

      Returns Promise<{ limited: number; maxed: number; paused: number; waiting: number }>

    • Gets the count of all the jobs belonging to any group.

      Returns Promise<number>

    • Get the given group status.

      Parameters

      • groupId: string

        The group id to get the status for.

      Returns Promise<GroupStatus>

      GroupStatus - The status of the group or null if the group does not exist.

    • Get library version.

      Returns Promise<string>

      the content of the meta.library field.

    • Completely destroys the queue and all of its contents irreversibly. This method will the pause the queue and requires that there are no active jobs. It is possible to bypass this requirement, i.e. not having active jobs using the "force" option.

      Note: This operation requires to iterate on all the jobs stored in the queue and can be slow for very large queues.

      Parameters

      • Optionalopts: { count?: number; force?: boolean }

        Obliterate options.

      Returns Promise<void>

    • Pauses the processing of a specific group globally.

      Adding jobs requires a LUA script to check first if the paused list exist and in that case it will add it there instead of the wait list or group list.

      Parameters

      • groupId: string | number

      Returns Promise<boolean>

    • Repairs a maxed group.

      It seems that in some unknown situations a group can become maxed although there are no active jobs in the group. This function will try to repair this situation.

      Parameters

      • groupId: string

        the group to repair

      Returns Promise<any>

    • Resumes the processing of a specific group globally.

      The method reverses the pause operation by resuming the processing of the group.

      Parameters

      • groupId: string | number

        the group to resume

      Returns Promise<boolean>