Module: taskcluster-client/exchange

taskcluster-client/exchange

Exchange constants and utilities for binding to queues...

Source:
Tutorials:

Members

<static, constant> QUEUE_TASK_COMPLETED

queue messages for completed tasks.

Source:

<static, constant> QUEUE_TASK_FAILED

queue messages for failed tasks.

Source:

<static, constant> QUEUE_TASK_PENDING

queue messages for pending tasks.

Source:

<static, constant> QUEUE_TASK_RUNNING :String

queue messages for running tasks.

Type:
  • String
Source:

<static, constant> QUEUE_TASKS :Array

Rollup of all task related exchanges

Type:
  • Array
Source:

Methods

<static> taskRoutingKey(options) → {String}

Parameters:
Name Type Description
options Object

for the routing key.

Properties
Name Type Argument Default Description
taskId String <optional>
*
runId String <optional>
*
workerGroup String <optional>
*
provisionerId String <optional>
*
workerType String <optional>
*
taskRouting String <optional>
#

defaults to # to allow additional dots (.)

Source:
See:
Returns:

routing key based on the object params.

Type
String
Example
var exchange = require('taskcluster-client/exchange');

var routingKey = exchange.taskRoutingKey({
  provisionerId: 'aws-provisioner',
  workerType: 'ami-xfoo'
});

// routingKey => '*.*.*.aws-provisoiner.ami-xfoo.#'