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
To help move past the boilerplate of creating new plugins, use Leiningen
with onyx-plugin to
generate a template.