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.static.default-vals
arg-or-default
default-vals
onyx.static.helpful-job-errors
bold-backticks
chain-phrases
chain-predicates
closest-match
conditional-failed*
contextual-depth
contextual-missing-key-error*
display-err-map-or-val
duplicate-entry-error*
entry-ordering-error*
error-left-padding
invalid-key*
invalid-onyx-type
line-wrap-str
malformed-value-error*
manual-ex
map-conditional-failed*
match-map-or-val
matches-faulty-key?
matches-map-key?
maybe-bad-key
missing-required-key*
multi-key-semantic-error*
mutually-exclusive-error*
pad
predicate-error-msg
print-helpful-job-error
print-helpful-job-error-and-throw
print-invalid-flow-to-type
print-invalid-key-error
print-invalid-task-name
print-invalid-task-name-error
print-invalid-workflow-task-name
print-multi-line-error
print-type-error
print-workflow-edge-error
print-workflow-element-error
relevant-key
restricted-value-error-msg
semantic-error-msgs
show-docs
show-footer
show-header
show-map
show-value
show-value*
show-vector
structure-names
type-error*
type-error-msg
value-choice-error*
value-conditional-failed*
value-predicate-error*
vec-of-maps-depth
wrap-str
wrap-vec
onyx.static.path-seq
app
path-seq
PathSeq
onyx.static.planning
create-task
discover-tasks
find-task
gen-task-ids
grouping-task?
max-depth
only
remove-dupes
to-dependency-graph
workflow-depth
onyx.static.pretty-print
blue
bold
bold-green
bold-red
magenta
onyx.static.swap-pair
swap-pair!
onyx.static.util
deserializable-exception
exception?
index-of
kw->fn
ms->ns
munge-fn-name
now
ns->ms
resolve-dynamic
onyx.static.uuid
random-uuid
onyx.static.validation
catalog->type-task-names
coerce-uuid
find-dupes
fixed-windows-dont-define-slide
global-windows-dont-define-range-or-slide
helpful-validate
min-and-max-peers-sane
min-max-n-peers-mutually-exclusive
no-duplicate-entries
print-schema-errors!
range-and-slide-units-compatible
session-windows-define-a-timeout
session-windows-dont-define-range-or-slide
session-windows-must-store-extents
sliding-windows-define-range-and-slide
trigger-id-unique-per-window
trigger-names-a-window
using-all-clause?
validate-all-position
validate-auto-short-circuit
validate-catalog
validate-env-config
validate-flow-conditions
validate-flow-connections
validate-flow-pred-all-kws
validate-flow-structure
validate-java-version
validate-job
validate-job-schema
validate-lifecycle-calls
validate-lifecycles
validate-none-position
validate-peer-client-config
validate-peer-config
validate-refinement-calls
validate-resume-point
validate-short-circuit
validate-state-aggregation-calls
validate-trigger-calls
validate-triggers
validate-windows
validate-workflow
validate-workflow-graph
validate-workflow-inputs
validate-workflow-intermediates
validate-workflow-names
validate-workflow-no-dupes
validate-workflow-reducers
window-ids-unique
window-incremental-extents-incompatible
window-key-where-required
window-names-a-task
cljdoc
is a website building & hosting documentation for Clojure/Script libraries
Keyboard shortcuts
Report a problem
cljdoc on GitHub
× close