Class FunctionRecordProcessor

An IRecordProcessor backed by a function.

Implements

IRecordProcessor

Index

Constructors

Methods

Constructors

constructor

new FunctionRecordProcessor(fn: RecordProcessorFn): FunctionRecordProcessor
Parameters
- fn: RecordProcessorFn
Returns FunctionRecordProcessor
- Defined in RecordSetProcessor/engine/src/processors/FunctionRecordProcessor.ts:20

Methods

ProcessRecord

ProcessRecord(
record: RecordRef,
context: RecordProcessorContext,
): Promise<RecordResult>
Processes one record.
Parameters
- record: RecordRef
  The record to process.
- context: RecordProcessorContext
  The per-record execution context.
Returns Promise<RecordResult>
The record's outcome (Succeeded / Failed / Skipped) plus any payload / trace links.
Implementation of IRecordProcessor.ProcessRecord
- Defined in RecordSetProcessor/engine/src/processors/FunctionRecordProcessor.ts:22