lib-onyx.replica-query — org.onyxplatform/lib-onyx 0.13.5.1-SNAPSHOT

completed-jobs clj/s

(completed-jobs replica)

Lists all the job ids that have been completed.

deref-replica clj/s

(deref-replica log-subscriber)

Derefences the replica as an immutable value.

host-peers clj/s

(host-peers replica)

job-allocations clj/s

(job-allocations replica)

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

job-scheduler clj/s

(job-scheduler replica)

Returns the job scheduler for this tenancy of the cluster.

job-state clj/s

(job-state replica job-id)

jobs clj/s

(jobs replica)

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

killed-jobs clj/s

(killed-jobs replica)

Lists all the job ids that have been killed.

peer->allocated-job clj/s

(peer->allocated-job replica id)

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

peer-site clj/s

(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/s

(peer-state replica peer-id)

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

peers clj/s

(peers replica)

Lists all the peer ids.

task->peer-sites clj/s

(task->peer-sites replica job-id task-id)

Given a job id and task-id return a map with peer-id->host-addr allocations for that task

task-allocations clj/s

(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/s

(task-scheduler replica job-id)

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

tasks clj/s

(tasks replica job-id)

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