Plugins serve as an abstract to compose mechanisms for getting data in and out of Onyx. See the README.md of the project for a list of official Onyx plugins, or keep reading to roll your own.
In order to implement a plugin, one or more protocols need to be implemented from the plugin interfaces.
Required interface implementations:
Plugin (stop/start)
Input
Checkpointed
BarrierSynchronization
Required interface implementations:
Plugin (stop/start)
Output
Checkpointed
BarrierSynchronization
To help move past the boilerplate of creating new plugins, use Leiningen
with onyx-plugin
to
generate a template.
Can you improve this documentation?Edit on GitHub
cljdoc builds & hosts documentation for Clojure/Script libraries
Ctrl+k | Jump to recent docs |
← | Move to previous article |
→ | Move to next article |
Ctrl+/ | Jump to the search field |