Options
All
  • Public
  • Public/Protected
  • All
Menu

conveyor-mq

Enumerations

Interfaces

Variables

Functions

Variables

Const debug

debug: Debugger = debugF('conveyor-mq:orchestrator')

Functions

Const createListener

  • createListener(__namedParameters: object): Listener

  • Creates a listener which listens for various task, queue and worker related events.

    Parameters

    • __namedParameters: object
      • events: undefined | EventType[]
      • queue: string
      • redisConfig: object
        • host: string
        • port: number

    Returns Listener

    listener

    • .onReady(): Promise - A function which returns a promise that resolves when the listener is ready.
    • .on(eventName, handler): void - A function which registers a handler function for a particular event.
    • .quit(): Promise - Quits the listener, disconnects the redis client and removes all handlers.

Const createManager

  • createManager(__namedParameters: object): Manager

  • Creates a manager which is responsible for enqueuing tasks, as well as querying various queue, task and worker properties.

    Parameters

    • __namedParameters: object
      • queue: string
      • redisConfig: object
        • host: string
        • port: number

    Returns Manager

    manager

    • .enqueueTask(task): Promise - Enqueues a task on the queue.
    • .enqueueTasks(tasks): Promise<Task[]> - Enqueues multiple tasks on the queue in a single transaction.
    • .scheduleTask(task): Promise - Schedules a task to be enqueued at a future date.
    • .scheduleTasks(tasks): Promise<Task[]> - Schedules multiple tasks in a single transaction.
    • .onTaskCompete(taskId): Promise - Returns a promise which resolves once the task is complete.
    • .getTaskById(taskId): Promise - Gets a task.
    • .getTasksById(taskIds): Promise<Task[]> - Gets a list of tasks in a single transaction.
    • .getTaskCounts(): Promise - Gets task counts by status.
    • .getWorkers(): Promise<Worker[]> - Gets workers on the queue.
    • .removeTaskById(taskId): Promise - Removes a task from the queue.
    • .destroyQueue(): Promise - Destroys the queue by removing all data & data structures.
    • .pauseQueue(): Promise - Pauses the queue.
    • .resumeQueue(): Promise - Resumes the queue.
    • .onReady(): Promise - Returns a promise which resolves once the manager is ready.
    • .quit(): Promise - Quits the manager, disconnects the redis clients.

      • Const createOrchestrator

      • createOrchestrator(__namedParameters: object): Orchestrator

      • Creates an orchestrator which is responsible for monitoring the queue for stalled tasks and re-enqueuing them if needed, as well as enqueuing scheduled tasks.

        Parameters

        • __namedParameters: object
          • defaultStallTimeout: number
          • queue: string
          • redisConfig: object
            • host: string
            • port: number
          • scheduledTasksCheckInterval: number
          • stalledCheckInterval: number

        Returns Orchestrator

        orchestrator

        • .onReady(): Promise - Returns a promise that resolves when the orchestrator is ready.
        • .quit(): Promise - Quits the orchestrator, terminating all intervals and the redis client.

      Const createWorker

      • createWorker(__namedParameters: object): Worker

      • Creates a worker which processes tasks on the queue.

        Parameters

        • __namedParameters: object
          • autoStart: boolean
          • concurrency: number
          • defaultStallTimeout: number
          • defaultTaskAcknowledgementInterval: undefined | number
          • getRetryDelay: undefined | function
          • handler: function
              • (__namedParameters: object): any

              • Parameters

                • __namedParameters: object
                  • task: Task
                  • updateTask: function
                      • (taskUpdateData: Partial<Task>): Promise<Task>

                      • Parameters

                        • taskUpdateData: Partial<Task>

                        Returns Promise<Task>

                  • updateTaskProgress: function
                      • (progress: any): Promise<Task>

                      • Parameters

                        • progress: any

                        Returns Promise<Task>

                Returns any

          • idleTimeout: number
          • onHandlerError: undefined | function
          • onIdle: undefined | function
          • onReady: undefined | function
          • onTaskError: undefined | function
          • onTaskFailed: undefined | function
          • onTaskSuccess: undefined | function
          • queue: string
          • redisConfig: object
            • host: string
            • port: number
          • removeOnFailed: boolean
          • removeOnSuccess: boolean

        Returns Worker

        worker

        • .onReady(): Promise - A function which returns a promise that resolves when the worker is ready.
        • .pause(): Promise - Pauses the worker from processing tasks.
        • .start(): Promise - Starts the worker processing tasks.
        • .shutdown(): Promise - Shuts down the worker and disconnects redis clients.
        • .onIdle(): Promise - Returns a promise which resolves once the worker is idle.

      Generated using TypeDoc