IPCTestJob

IPCTestJob

Class for testing ipc jobs

Constructor

new IPCTestJob()

Source:

Methods

createResource(_id, name, db) → {Resource}

Source:

Create resource

Parameters:
Name Type Description
_id string

resource _id

name string

resource name

db Db

db connection

Returns:

resource

Type
Resource

getConcurrency() → {number}

Source:

Get concurrency

Returns:

concurency

Type
number

(async) prepare(manager, db)

Source:

Prepare the job

Parameters:
Name Type Description
manager object

resource manager

db Db

db connection

resourceName() → {string}

Source:

Get resource name

Returns:

resource name

Type
string

retryPolicy() → {RetryPolicy}

Source:

Get retry policy

Returns:

retry policy

Type
RetryPolicy

(async) run(db)

Source:

Run the job

Parameters:
Name Type Description
db Db

connection