org.onyxplatform/onyx
0.14.6
cljdoc
onyx-platform/onyx
Liking cljdoc? Tell your friends :D
Articles
Readme
Changelog
Example 2: 3 node cluster, 1 job, Greedy job scheduler, Round Robin task scheduler
Onyx Batch Processing Design
Coordination Scalability
serialization
Scratch pad for Task Lifecycle Redesign
Onyx Windowing
Branch Policy
Deployment Process
Release Checklist
0.4.0
0.5.0
0.6.0
0.7.0
0.8.0
Aggregation & State Management
APIs
Architecture & Low Level Design
Backpressure
Concepts
onyx-core-async
Deployment
Environment
Examples
Frequently Asked Questions
Flow Conditions
Functions
User Guide
Information Model
Example 1: 3 node cluster, 1 peer successfully joins
Example 2: 3 node cluster, 2 peers successfully join
Example 3: 2 node cluster, 1 peer successfully joins, 1 aborts
Example 4: 1 node cluster, 1 peer successfully joins
Example 5: 0 node cluster, 1 peer successfully joins
Example 6: 3 node cluster, 1 peer fails to join due to 1 peer dying during 3-phase join
Example 7: 3 node cluster, 1 peer dies while joining
Example 1: 4 node cluster, 1 peer crashes
Example 2: 4 node cluster, 2 peers instantaneously crash
Lifecycles
Logging
Messaging
Monitoring
Performance Tuning
Plugins
Production Check List
Resume Points
Scheduling
onyx-seq
Event Subscription
Testing Onyx Jobs
Triggers
Watermarks
What does Onyx offer?
Windowing and Aggregation
Namespaces
onyx
api
checkpoint
compression
nippy
doc
extensions
flow-conditions
fc-compile
fc-routing
gc
information-model
interop
job
log
commands
abort-join-cluster
add-virtual-peer
common
group-leave-cluster
kill-job
leave-cluster
notify-join-cluster
prepare-join-cluster
submit-job
curator
entry
failure-detector
replica
replica-invariants
zookeeper
messaging
aeron-media-driver
aeron
embedded-media-driver
endpoint-status
messaging-group
publisher
status-publisher
subscriber
utils
messenger-state
protocols
endpoint-status
messenger
publisher
status-publisher
subscriber
serialize
short-circuit
monitoring
measurements
metrics-monitoring
no-op-monitoring
peer
communicator
constants
coordinator
function
grouping
liveness
log-version
operation
peer-group-manager
queryable-state-manager
resume-point
status
plugin
core-async
messaging-output
null
protocols
seq
protocol
task-state
query
scheduling
balanced-job-scheduler
balanced-task-scheduler
colocated-task-scheduler
common-job-scheduler
common-task-scheduler
percentage-job-scheduler
percentage-task-scheduler
schema
seq
information-model
state
lmdb
memory
open-checkpoint-db
protocol
db
serializers
checkpoint
group-decoder
group-encoder
group-reverse-decoder
group-reverse-encoder
state-entry-key-decoder
state-entry-key-encoder
utils
static
default-vals
helpful-job-errors
path-seq
planning
pretty-print
swap-pair
util
uuid
validation
storage
s3
system
tasks
core-async
function
null
seq
test-helper
triggers
types
windowing
aggregation
units
window-extensions
window-id
onyx.scheduling.balanced-job-scheduler
select-job-requiring-peer
onyx.scheduling.balanced-task-scheduler
reuse-spare-peers
onyx.scheduling.colocated-task-scheduler
ban-smaller-sites
choose-candidates
find-colocated-peers
get-peer-site
global-saturation-lower-bound
large-enough-sites
non-colocated-tasks
select-peers
site->peers
onyx.scheduling.common-job-scheduler
actual-usage
add-allocation-versions
add-messaging-short-ids
anti-jitter-constraints
assign-coordinators
assign-task-resources
assign-task-slot-ids
btr-place-scheduling
build-current-model
build-job-and-task->node
build-node->task
build-peer->task
build-peer->vm
calculate-capacity
capacity-constraints
change-peer-allocations
claim-spare-peers
constrainted-tasks-for-peer
deallocate-starved-jobs
full-allocation?
grouped-task?
grouping-task-constraints
input-task?
job->planned-task-capacity
job-claim-peers
job-coverable?
job-lower-bound
job-offer-n-peers
job-upper-bound
messaging-long-form
n-no-op-tasks
n-qualified-peers
no-tagged-peers-constraints
peer-running-constraints
reallocate-peers
reconfigure-cluster-workload
remove-job
slot-ids
src-peers
task-tagged-constraints
to-node-array
unassign-task-slot-ids
unconstrained-tasks
unrolled-tasks
update-peer-site
update-slot-id-for-peer
onyx.scheduling.common-task-scheduler
assign-capacity-constraint?
choose-acker
choose-downstream-peers
preallocated-grouped-task?
task-constraints
task-distribute-peer-count
onyx.scheduling.greedy-job-scheduler
No vars found in this namespace.
onyx.scheduling.percentage-job-scheduler
desired-allocation
drop-jobs-overflow
min-allocations
rotate
select-job-requiring-peer
sort-jobs-by-pct
onyx.scheduling.percentage-task-scheduler
largest-remainder-allocations
percentage-balanced-taskload
reduce-overallocated-peers
remove-grouping-tasks
rescale-task-percentages
tasks-by-pct
cljdoc
builds & hosts documentation for Clojure/Script libraries
Keyboard shortcuts
Ctrl
+
k
Jump to recent docs
←
Move to previous article
→
Move to next article
Ctrl
+
/
Jump to the search field
Raise an issue
Browse cljdoc source
Chat on Slack
× close