onyx.test-helper — org.onyxplatform/onyx 0.14.6

add-test-env-peers! clj

(add-test-env-peers! {:keys [peer-group peers] :as component} n-peers)

Add peers to an OnyxTestEnv component

feedback-exception! clj

(feedback-exception! peer-client-config job-id)

(feedback-exception! peer-client-config job-id log)

Feeds an exception that killed a job back to a client. Blocks until the job is complete.

find-task clj

(find-task catalog task-name)

get-counts clj

(get-counts replica job-infos)

job->min-peers-per-task clj

(job->min-peers-per-task {:keys [catalog workflow] :as job})

job-allocation-counts clj

(job-allocation-counts replica job-info)

load-config clj

(load-config)

(load-config filename)

playback-log clj

(playback-log log replica ch timeout-ms)

shutdown-env clj

(shutdown-env env)

shutdown-peer clj

(shutdown-peer v-peer)

shutdown-peer-group clj

(shutdown-peer-group peer-group)

try-start-env clj

(try-start-env env-config)

try-start-group clj

(try-start-group peer-config)

try-start-peers clj

(try-start-peers n-peers peer-group)

validate-enough-peers! clj

(validate-enough-peers! test-env job)

Checks that the test environment will start enough peers to start the job. Do not use this validation function in production as it does not check for the number of peers running over a cluster, and the number of peers that has joined is subject to change as nodes come online and go offline.

with-components clj macro

(with-components bindings & body)

with-test-env clj macro

(with-test-env [symbol-name [n-peers env-config peer-config]] & body)

Start a test env in a way that shuts down after body is completed. Useful for running tests that can be killed, and re-run without bouncing the repl.