Onyx 0.14.1

Distributed, masterless, high performance, fault tolerant data processing for Clojure

onyx.api

onyx.checkpoint

Onyx checkpoint interfaces.

onyx.compression.nippy

onyx.doc

Public variables and functions:

onyx.extensions

Extension interfaces for internally used queues, logs,
and distributed coordination.

onyx.flow-conditions.fc-compile

onyx.flow-conditions.fc-routing

onyx.gc

onyx.information-model

onyx.interop

onyx.job

onyx.log.commands.abort-join-cluster

Public variables and functions:

onyx.log.commands.accept-join-cluster

Public variables and functions:

    onyx.log.commands.add-virtual-peer

    Public variables and functions:

    onyx.log.commands.common

    onyx.log.commands.complete-job

    Public variables and functions:

      onyx.log.commands.gc

      Public variables and functions:

        onyx.log.commands.group-leave-cluster

        Public variables and functions:

        onyx.log.commands.kill-job

        Public variables and functions:

        onyx.log.commands.leave-cluster

        Public variables and functions:

        onyx.log.commands.notify-join-cluster

        Public variables and functions:

        onyx.log.commands.prepare-join-cluster

        Public variables and functions:

        onyx.log.commands.set-replica

        Public variables and functions:

          onyx.log.commands.submit-job

          onyx.log.curator

          onyx.log.entry

          Public variables and functions:

          onyx.log.failure-detector

          onyx.log.replica

          Public variables and functions:

          onyx.log.replica-invariants

          onyx.log.zookeeper

          onyx.messaging.aeron-media-driver

          Public variables and functions:

          onyx.messaging.aeron.embedded-media-driver

          onyx.messaging.aeron.endpoint-status

          onyx.messaging.aeron.messaging-group

          onyx.messaging.aeron.publisher

          onyx.messaging.aeron.status-publisher

          Public variables and functions:

          onyx.messaging.aeron.subscriber

          onyx.messaging.aeron.utils

          onyx.messaging.messenger-state

          onyx.messaging.protocols.endpoint-status

          Public variables and functions:

          onyx.messaging.protocols.messenger

          onyx.messaging.protocols.publisher

          Public variables and functions:

          onyx.messaging.protocols.status-publisher

          Public variables and functions:

          onyx.messaging.protocols.subscriber

          Public variables and functions:

          onyx.messaging.serialize

          Public variables and functions:

          onyx.messaging.short-circuit

          onyx.monitoring.custom-monitoring

          Public variables and functions:

          onyx.monitoring.measurements

          onyx.monitoring.metrics-monitoring

          onyx.monitoring.no-op-monitoring

          onyx.peer.communicator

          onyx.peer.constants

          onyx.peer.coordinator

          onyx.peer.function

          Public variables and functions:

          onyx.peer.liveness

          Public variables and functions:

          onyx.peer.log-version

          Public variables and functions:

          onyx.peer.operation

          onyx.peer.peer-group-manager

          onyx.peer.queryable-state-manager

          onyx.peer.resume-point

          onyx.peer.status

          Public variables and functions:

          onyx.plugin.messaging-output

          onyx.plugin.null

          Public variables and functions:

          onyx.plugin.protocols

          onyx.plugin.seq

          onyx.protocol.task-state

          Public variables and functions:

          onyx.query

          Public variables and functions:

          onyx.refinements

          Public variables and functions:

            onyx.scheduling.balanced-job-scheduler

            Public variables and functions:

            onyx.scheduling.balanced-task-scheduler

            Public variables and functions:

            onyx.scheduling.colocated-task-scheduler

            onyx.scheduling.common-job-scheduler

            onyx.scheduling.common-task-scheduler

            onyx.scheduling.greedy-job-scheduler

            Public variables and functions:

              onyx.scheduling.percentage-job-scheduler

              onyx.scheduling.percentage-task-scheduler

              onyx.schema

              Public variables and functions:

              onyx.seq.information-model

              Public variables and functions:

              onyx.state.lmdb

              Implementation of a LMDB backed state store. Currently this is alpha level quality.

              onyx.state.open-checkpoint-db

              Public variables and functions:

              onyx.state.protocol.db

              Public variables and functions:

              onyx.state.serializers.checkpoint

              Streaming serializer / deserializer for state checkpoints.

              onyx.state.serializers.group-decoder

              Public variables and functions:

              onyx.state.serializers.group-encoder

              Public variables and functions:

              onyx.state.serializers.group-reverse-decoder

              Public variables and functions:

              onyx.state.serializers.group-reverse-encoder

              Public variables and functions:

              onyx.state.serializers.state-entry-key-decoder

              onyx.state.serializers.state-entry-key-encoder

              onyx.state.serializers.utils

              onyx.static.default-vals

              Public variables and functions:

              onyx.static.path-seq

              Public variables and functions:

              onyx.static.planning

              onyx.static.swap-pair

              Public variables and functions:

              onyx.static.util

              onyx.static.uuid

              Public variables and functions:

              onyx.storage.s3

              onyx.system

              onyx.tasks.core-async

              Public variables and functions:

              onyx.tasks.function

              Public variables and functions:

              onyx.tasks.null

              Public variables and functions:

              onyx.tasks.seq

              onyx.test-helper

              onyx.triggers

              onyx.types

              onyx.windowing.aggregation

              onyx.windowing.units

              Public variables and functions:

              onyx.windowing.window-extensions