Liking cljdoc? Tell your friends :D
onyx.api
- await-job-completion
- build-resume-point
- clear-checkpoints
- clear-job-data
- clear-tenancy
- gc
- gc-checkpoints
- job-ids-history
- job-snapshot-coordinates
- job-state
- kill-job
- map-set-workflow->workflow
- named-job-snapshot-coordinates
- shutdown-env
- shutdown-peer
- shutdown-peer-group
- shutdown-peers
- start-env
- start-peer-group
- start-peers
- submit-job
- subscribe-to-log
- validate-submission
onyx.checkpoint
Onyx checkpoint interfaces.
Onyx checkpoint interfaces.
- assume-checkpoint-coordinate
- cancel!
- complete?
- gc-checkpoint!
- gc-replica-epoch-watermark!
- read-all-replica-epoch-watermarks
- read-checkpoint
- read-checkpoint-coordinate
- read-replica-epoch-low-watermark
- stop
- storage
- watch-checkpoint-coordinate
- write-checkpoint
- write-checkpoint-coordinate
- write-replica-epoch-low-watermark
- write-replica-epoch-watermark
onyx.compression.nippy
- checkpoint-compress
- checkpoint-compress-opts
- checkpoint-decompress
- checkpoint-decompress-opts
- messaging-compress
- messaging-compress-opts
- messaging-decompress
- messaging-decompress-opts
- statedb-compress
- statedb-decompress
- window-log-compress
- window-log-decompress
- window-log-decompress-opts
- zookeeper-compress
- zookeeper-compress-opts
- zookeeper-decompress
- zookeeper-decompress-opts
onyx.extensions
Extension interfaces for internally used queues, logs, and distributed coordination.
Extension interfaces for internally used queues, logs, and distributed coordination.
- apply-log-entry
- connected?
- fire-side-effects!
- force-write-chunk
- gc-log-entry
- group-exists?
- IEmitEvent
- job-status
- monitoring-agent
- new-task-state!
- on-delete
- reactions
- read-chunk
- read-job-name-metadata
- read-log-entry
- register-pulse
- replica-diff
- subscribe-to-log
- update-origin!
- write-chunk
- write-job-name-metadata
- write-log-entry
onyx.log.commands.accept-join-cluster
No vars found in this namespace.
onyx.log.commands.common
- allocations->peers
- build-stop-task-fn
- grouped-task?
- input-task?
- job->peers
- job-allocations->peer-ids
- job-peer-count
- leaf-tasks
- messenger-slot-id
- peer->allocated-job
- promote-orphans
- remove-peers
- replica->job-peers
- root-tasks
- src-peers
- start-new-lifecycle
- start-task!
- state-task?
- stop-lifecycle-peer-group!
- to-graph
- upstream-peers
onyx.log.commands.complete-job
No vars found in this namespace.
onyx.log.commands.gc
No vars found in this namespace.
onyx.log.commands.set-replica
No vars found in this namespace.
onyx.log.replica-invariants
- active-job-invariant
- all-coordinators-exist
- all-groups-invariant
- all-jobs-have-coordinator
- all-peers-are-group-indexed
- all-peers-are-reverse-group-indexed
- all-tasks-have-non-zero-peers
- allocations-invariant
- group-index-keys-never-nil
- group-index-vals-never-nil
- no-extra-coordinators
- peer-site-invariant
- short-identifiers-correct
- slot-id-invariant
- version-invariant
onyx.log.zookeeper
- await-entry!
- catalog-path
- checkpoint-path
- checkpoint-path-version
- checkpoint-task-key
- chunk-path
- clean-up-broken-connections
- clear-job-data
- clear-tenancy
- current-replica
- epoch-low-watermark-path
- epoch-path
- exception-path
- find-log-parameters
- flow-path
- global-metadata-path
- initialize-origin!
- job-config-path
- job-hash-path
- job-metadata-path
- job-name-path
- job-paths
- latest-checkpoint-path
- lifecycles-path
- log-parameters-path
- log-path
- origin-path
- pad-sequential-id
- parse-task-key
- poll-znode-timeout-ms
- prefix-path
- pulse-path
- read-checkpoint-coord
- read-log-entry
- read-log-parameters
- read-origin
- receive-event
- resume-point-path
- root-path
- savepoint-path
- seek-and-put-entry!
- seek-to-new-origin!
- task-path
- tenancy-alive?
- throw-subscriber-closed
- triggers-path
- windows-path
- workflow-path
- znode
- znode-path
- zookeeper
onyx.monitoring.custom-monitoring
No vars found in this namespace.
onyx.peer.coordinator
- barrier-period
- check-peer-timeout!
- checkpoint-complete?
- complete-job
- completed-checkpoint
- Coordinator
- coordinator-backoff-ms
- coordinator-iteration
- emit-replica
- emit-seal-barrier
- evict-peer!
- initialise-state
- input-publications
- make-task-data
- merged-statuses
- new-peer-coordinator
- next-replica
- offer-barriers
- offer-heartbeats
- periodic-barrier
- schedule-next-barrier
- shutdown
- start-coordinator!
- start-messenger
- stop-coordinator!
- write-coordinate
onyx.peer.peer-group-manager
- action
- annotate-reaction
- futures-stuck-park-ms
- idle-backoff-ms
- media-driver-backoff-ms
- peer-group-error-backoff-ms
- peer-group-manager
- peer-group-manager-loop
- peers-allocated-proportion
- poll-inbox!
- remove-shutdown-futs
- safe-stop-vpeer!
- setup-group-state
- shutting-down-task-metrics
- spin-park-ms
- spin-until-tasks-shutdown
- start-communicator!
- transition-group
- transition-peers
- update-scheduler-lag!
onyx.refinements
No vars found in this namespace.
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.greedy-job-scheduler
No vars found in this namespace.
onyx.schema
- add-event-schema
- add-state-event-schema
- AeronIdleStrategy
- BarrierCoordinate
- base-task-map
- build-allowed-key-ns
- Catalog
- combine-restricted-ns
- deprecated
- EnvConfig
- Epoch
- Event
- FlowAction
- FlowCondition
- FluxPolicy
- FnPath
- Function
- function-task-map
- GroupId
- grouping-task?
- information-model->schema
- InitialiseMode
- input-task-map
- InputResumeDefinition
- InputResumeMode
- java?
- Job
- JobConfig
- JobId
- JobMetadata
- JobName
- JobScheduler
- Language
- Lifecycle
- LifecycleCall
- LifecycleState
- LogEntry
- lookup-schema
- Messaging
- NamespacedKeyword
- NonNamespacedKeyword
- output-task-map
- OutputResumeDefinition
- OutputResumeMode
- partial-clojure-fn-task
- partial-clojure-plugin
- partial-fn-task
- partial-grouping-task
- partial-input-task
- partial-java-fn-task
- partial-java-plugin
- partial-output-task
- partial-reduce-task
- PartialJob
- PartialWorkflow
- PeerClientConfig
- PeerConfig
- PeerId
- PeerSchedulerEvent
- PeerSite
- PeerZKClientConfig
- PosInt
- Reactions
- reduce-task-map
- RefinementCall
- Replica
- ReplicaDiff
- ReplicaVersion
- restricted-ns
- RestrictedKwNamespace
- ResumeCoordinate
- ResumePoint
- schema-name->schema
- SegmentKey
- SlotId
- SlotMigration
- SpecialFlowTasks
- SPosInt
- State
- StateAggregationCall
- StateEvent
- StateFilterImpl
- StateLogImpl
- Storage
- TaskId
- TaskMap
- TaskName
- TaskScheduler
- TenancyId
- TenancyIdStr
- Trigger
- TriggerCall
- TriggerDelay
- TriggerDelayElements
- TriggerEvent
- TriggerEventType
- TriggerId
- TriggerPeriod
- TriggerPeriodElements
- TriggerRefinement
- TriggerState
- TriggerThreshold
- TriggerThresholdElements
- type->schema
- UniqueTaskMap
- Unit
- UnsupportedFlowKey
- UnsupportedTriggerKey
- UnsupportedWindowKey
- valid-min-peers-max-peers-n-peers?
- Window
- WindowBase
- WindowExtension
- WindowId
- WindowResumeDefinition
- WindowResumeMode
- WindowState
- WindowType
- Workflow
onyx.state.lmdb
Implementation of a LMDB backed state store. Currently this is alpha level quality.
Implementation of a LMDB backed state store. Currently this is alpha level quality.
onyx.state.serializers.checkpoint
Streaming serializer / deserializer for state checkpoints.
Streaming serializer / deserializer for state checkpoints.
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.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
onyx.triggers
- exceeds-percentile-watermark?
- exceeds-watermark?
- next-fire-time
- percentile-watermark
- percentile-watermark-fire?
- punctuation
- punctuation-fire?
- punctuation-init-locals
- punctuation-init-state
- punctuation-next-state
- segment
- segment-fire?
- segment-init-state
- segment-next-state
- timer
- timer-fire?
- timer-init-state
- timer-next-state
- watermark
- watermark-fire?
- watermark-init-locals
onyx.windowing.aggregation
- average
- average-aggregation-apply-fn
- average-aggregation-create-fn
- average-aggregation-fn-init
- average-super-aggregation
- collect-by-key
- collect-by-key-aggregation-apply-log
- collect-by-key-aggregation-fn
- collect-by-key-aggregation-fn-init
- collect-by-key-super-aggregation
- collect-key-value
- collect-key-value-aggregation-apply-log
- collect-key-value-aggregation-fn
- collect-key-value-aggregation-fn-init
- collect-key-value-super-aggregation
- conj
- conj-aggregation-apply-log
- conj-aggregation-fn
- conj-aggregation-fn-init
- conj-super-aggregation
- count
- count-aggregation-apply-fn
- count-aggregation-create-state-update
- count-aggregation-fn-init
- count-super-aggregation
- max
- max-aggregation-fn
- max-create-aggregation-apply-fn
- max-super-aggregation
- min
- min-aggregation-apply-fn
- min-aggregation-create-fn
- min-super-aggregation
- set-value-aggregation-apply-log
- sum
- sum-aggregation-fn-init
- sum-aggregation-function
- sum-create-state-update-fn
- sum-super-aggregation
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close