|Configurable<C extends StageConfig>||
Something that can be configured (data source, pipeline stage, aggregation, etc)
Additional context to pass along with messages in the pipeline
|Generator<M,C extends StageConfig>||
A stateful stage that generates documents Since a Generator can stop itself, it adds an onFinished listener
Something that can be started and stopped
Something that can accept and process a message
|Stage<M,C extends StageConfig>||
The basic unit of a pipeline, a stage
|StageAssistFactory<M,T extends Stage<M,? extends StageConfig>>||
Base factory interface for use with Guice assisted inject factories.
Used for constructing
Something for stages to write messages to
Marker interface to indicate a Stage has side-effects
DON'T EXTEND THIS DIRECTLY.
|AbstractGenerator<M,C extends StageConfig>|
Manages the set of currently known Pipelines TODO extract an interface for the history stuff, store history in Solr
|AbstractProcessor<M,C extends StageConfig>|
|AbstractStage<M,C extends StageConfig>|
A MetricRegistry which presents a "view" of a wrapped MetricRegistry All metric names are automatically prefixed going into the wrapped registry, and stripped of the prefix on the way out.
Main runtime support for a pipeline (the actual thing that runs) Controls wiring the stages together, starting, and stopping them.
Definition of a pipeline (its stages and properties)
POJO used by the API to transition a Pipeline from one state to another TODO how to reduce redundancy between this State and the Pipeline.State?
Represents a snapshot of the Pipeline's state.
Decorates a Stage instance with some telemetry and bounds checking
Base class for configuration POJOs
Something that is intended to be auto-discovered by classpath scanning.