Interface | Description |
---|---|
AbstractBlobsRegistrar.BiConsumer<T,U> |
I want a BiConcumer that WILL yield a RESTError for my lambdas
|
AbstractBlobsRegistrar.Supplier<T> |
i want a Supplier like interface that WILL yield a RESTError for my lambdas
|
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 | |
Generator<M,C extends StageConfig> |
A stateful stage that generates documents
Since a Generator can stop itself, it adds an onFinished listener
|
InterProcessLockFactory | |
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
|
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 |
---|---|
AbstractBlobsRegistrar | |
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> | |
AutocompleteBlobsLoader |
used to load the autocomplete blobs
|
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.
|
DefaultInterProcessLockFactory | |
IndexPipelineDefinition | |
LinksEvent | |
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 | |
QuickstartBlobsRegistrar |
load the quickstart blobs
|
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.
|