| Interface | Description |
|---|---|
| BasePipelineComponent<T extends PipelineDefinition<T>,M> |
Contract for all components to fulfill basic pipeline requirements.
|
| Configurable<C extends StageConfig> |
Something that can be configured (data source, pipeline stage, aggregation, etc)
|
| Context |
Additional context to pass along with messages in the pipeline
|
| ContextFactory | |
| DeprecatedContext | Deprecated |
| Generator<M,C extends StageConfig> |
A stateful stage that generates documents
Since a Generator can stop itself, it adds an onFinished listener
|
| Lifecycle |
Something that can be started and stopped
|
| PipelineDefinitionFactory<T extends PipelineDefinition<T>> | |
| PipelineDefinitionRegistry<T extends PipelineDefinition<T>> | |
| PipelineManager<M> | |
| Processor<M> |
Something that can accept and process a message
|
| PropertyContext | |
| 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.
|
| StageCallback<M> | |
| StageFactory<M> |
Used for constructing
Stage instances
The arguments here represent the set of dependencies provide by the pipelines framework. |
| StageOutput<M> |
Something for stages to write messages to
|
| WithSideEffects |
Marker interface to indicate a Stage has side-effects
|
| Class | Description |
|---|---|
| AbstractDefaultPipelineRegistrar<T extends PipelineDefinition<T>> |
DON'T EXTEND THIS DIRECTLY.
|
| AbstractGenerator<M,C extends StageConfig> | |
| AbstractPipelineManager<M> |
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> | |
| AbstractStageFactory<M> | |
| AbstractStageFactory.StageImpl<M> | |
| BaseRPCConfig |
Common base for the Indexing and Query RPC/REST stages.
|
| BaseSchemaGrouping | |
| BlobsBasedPipelineRegistrar<T extends PipelineDefinition<T>> | |
| Context.Signal | |
| DefaultBasePipelineComponent<T extends PipelineDefinition<T>,M> |
Base implementation of the BasePipelineComponent.
|
| FusionMetricConstants |
convenience constants class to hold metric literals and their descriptions
|
| IndexPipelineDefinition | |
| LinksEvent | |
| MatchRule |
A generic matching rule that can be used across pipeline stages
|
| MetricRegistryView |
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.
|
| Pipeline<M> |
Main runtime support for a pipeline (the actual thing that runs)
Controls wiring the stages together, starting, and stopping them.
|
| PipelineDefinition<T extends PipelineDefinition<T>> |
Definition of a pipeline (its stages and properties)
|
| PipelineDefinitionMergeUtil | |
| PipelineErrors | |
| PipelineStateTransition |
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?
|
| PipelineStatus |
Represents a snapshot of the Pipeline's state.
|
| QueryPipelineDefinition | |
| RegexFilterRule | |
| RuntimeStage<M> |
Decorates a Stage instance with some telemetry and bounds checking
|
| RuntimeStage.ThrowableAndMessage<M> | |
| StageAssistFactoryParams | |
| StageConfig |
Base class for configuration POJOs
|
| StageConfig.Category |
| Enum | Description |
|---|---|
| Pipeline.State | |
| PipelineStateTransition.State |
| Exception | Description |
|---|---|
| AbstractDefaultPipelineRegistrar.PipelineRegistrarException |
| Annotation Type | Description |
|---|---|
| AutoDiscover |
Something that is intended to be auto-discovered by classpath scanning.
|