lib-onyx.replica-query — org.onyx-platform/lib-onyx 0.8.12.0-SNAPSHOT

completed-jobs clj

(completed-jobs replica)

Lists all the job ids that have been completed.

deref-replica clj

(deref-replica log-subscriber)

Takes a log subscriber and derefences the replica as an immutable value.

job-allocations clj

(job-allocations replica)

Returns a map of job id -> task id -> peer ids, denoting which peers are assigned to which tasks.

job-scheduler clj

(job-scheduler replica)

Returns the job scheduler for this tenancy of the cluster.

jobs clj

(jobs replica)

Lists all non-killed, non-completed job ids.

killed-jobs clj

(killed-jobs replica)

Lists all the job ids that have been killed.

peer-allocation clj

(peer-allocation replica peer-id)

Given a peer id, returns the job id and task id that this peer is currently assigned to, if any.

peer-site clj

(peer-site replica peer-id)

Given a peer id, returns the Aeron hostname and port that this peer advertises to the rest of the cluster.

peer-state clj

(peer-state replica peer-id)

Given a peer id, returns its current execution state (e.g. :idle, :active, etc).

peers clj

(peers replica)

Lists all the peer ids.

task-allocations clj

(task-allocations replica job-id)

Given a job id, returns a map of task id -> peer ids, denoting which peers are assigned to which tasks for this job only.

task-scheduler clj

(task-scheduler replica job-id)

Given a job id, returns the task scheduler for this job.

tasks clj

(tasks replica job-id)

Given a job id, returns all the task ids for this job.