Class PipelineProcessor

Runs the configured stages over one record at a time. Built once per run.

Implements

IRecordProcessor

Index

Constructors

Properties

Accessors

Methods

Constructors

constructor

new PipelineProcessor(
    config: PipelineProcessorConfig,
    storage?: StorageFactories,
    progress?: ProgressReporter,
): PipelineProcessor
Parameters
- config: PipelineProcessorConfig
- storage: StorageFactories = DefaultStorageFactories
- Optionalprogress: ProgressReporter
Returns PipelineProcessor
- Defined in ContentPipeline/engine/src/PipelineProcessor.ts:81

Properties

`Optional`ProcessBatch

ProcessBatch?: (
records: RecordRef[],
context: RecordProcessorContext,
) => Promise<Map<string, RecordResult>>

Present only when the last stage has a Finalize; Record Set Processing checks for it.

Accessors

Stages

get Stages(): readonly BasePipelineStage[]
The resolved stages, in run order.

Returns readonly BasePipelineStage[]
- Defined in ContentPipeline/engine/src/PipelineProcessor.ts:105

Methods

ProcessRecord

ProcessRecord(
record: RecordRef,
context: RecordProcessorContext,
): Promise<RecordResult>
Hydrate, run the stages, commit children then the record (unless a test), return the outcome.
Parameters
- record: RecordRef
- context: RecordProcessorContext
Returns Promise<RecordResult>
Implementation of IRecordProcessor.ProcessRecord
- Defined in ContentPipeline/engine/src/PipelineProcessor.ts:114