See /docs/coordinator-api.txt for documentation

AdapterManager doesn't ever make changes to the Mongo Adapter fields. It is read-only. (with the exception of status information) It's up to the adapt

Commands supported or will be supported: NEW,ADD,STOP,RESET,CHANGE_PRIORITY

Coordinator Heartbeat Bolt performs extra actions compared to adapter level version. The coordinator takes advantage of this interval to run a few cl

See /docs/coordinator-api.txt for documentation

Job Failure Exceptions are thrown when there is a fatal error with job processing.

Note: job_config is stored as a string so mongo can store it. If we stored as JSONObject, we were running into problems where .'s or $'s in the key na

Tasks are always stored in database until a job is "DELETED" or "PURGED"

DbValues are always stored in database until a job is "DELETED" or "PURGED"

Handles communication layer to LemonGraph { "nodes":[], "meta":{"job_id":"b202cca8-f03a-11e5-8ba5-000000000000", priority:255, enabled:0/1}, "

(Content-Type: application/json, application/x-msgpack) body should be object w/ the optional kv pairs below { "seed": true, // mark any referenc

Perform tests that don't need the LEMONGRAPH server to be actually running

Dealing with common result variables from LemonGraph Communication LemonGraph sends result variables in Response headers for Posts. jobId is only pop

Note: Probably leave this test out of the testSuite because these tests fail if LemonGraph.Server is not running. This test moved to api module to p

Reads the topology configuration file and starts the adapters It takes a command line topology file name as the first argument and will attempt to loa

Used for testing job cancel code This adapter will call itself 5 times and sleep 30 seconds each iteration.

Helper internal class that maintains the metrics return values