Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type IndexingExecutor ¶
type IndexingExecutor struct {
// contains filtered or unexported fields
}
IndexingExecutor executes indexing pipelines.
func NewIndexingExecutor ¶
func NewIndexingExecutor( builder pipelineport.PipelineBuilder, pipelineRegistry pipelineport.PipelineRegistry, capRegistry pipelineport.CapabilityRegistry, manifestStore pipelineport.ManifestStore, stageRegistry pipelineport.StageRegistry, ) *IndexingExecutor
NewIndexingExecutor creates a new indexing executor.
func (*IndexingExecutor) Execute ¶
func (e *IndexingExecutor) Execute( ctx context.Context, pctx *pipeline.IndexingContext, input *pipeline.IndexingInput, ) (*pipeline.IndexingOutput, error)
Execute runs an indexing pipeline for a single document.
func (*IndexingExecutor) ExecuteBatch ¶
func (e *IndexingExecutor) ExecuteBatch( ctx context.Context, pctx *pipeline.IndexingContext, inputs []*pipeline.IndexingInput, ) ([]*pipeline.IndexingOutput, error)
ExecuteBatch runs an indexing pipeline for multiple documents.
type PipelineBuilder ¶
type PipelineBuilder struct {
// contains filtered or unexported fields
}
PipelineBuilder constructs executable pipelines from definitions.
func NewPipelineBuilder ¶
func NewPipelineBuilder(stageRegistry pipelineport.StageRegistry) *PipelineBuilder
NewPipelineBuilder creates a new pipeline builder.
func (*PipelineBuilder) Build ¶
func (b *PipelineBuilder) Build(def pipeline.PipelineDefinition, capabilities *pipeline.CapabilitySet) (pipelineport.ExecutablePipeline, error)
Build constructs a pipeline from a definition.
func (*PipelineBuilder) Validate ¶
func (b *PipelineBuilder) Validate(def pipeline.PipelineDefinition) error
Validate checks if a pipeline definition is valid.
type SearchExecutor ¶
type SearchExecutor struct {
// contains filtered or unexported fields
}
SearchExecutor executes search pipelines.
func NewSearchExecutor ¶
func NewSearchExecutor( builder pipelineport.PipelineBuilder, pipelineRegistry pipelineport.PipelineRegistry, capRegistry pipelineport.CapabilityRegistry, stageRegistry pipelineport.StageRegistry, ) *SearchExecutor
NewSearchExecutor creates a new search executor.
func (*SearchExecutor) Execute ¶
func (e *SearchExecutor) Execute( ctx context.Context, sctx *pipeline.SearchContext, input *pipeline.SearchInput, ) (*pipeline.SearchOutput, error)
Execute runs a search pipeline.
Source Files
Click to show internal directories.
Click to hide internal directories.