Class PipelineTransformationEntrypoint<Env, I, O>`Abstract`

Type Parameters

Env = unknown
I extends PipelineRecord = PipelineRecord
O extends PipelineRecord = PipelineRecord

Index

Constructors

Properties

Methods

Constructors

constructor

new PipelineTransformationEntrypoint<
    Env = unknown,
    I extends PipelineRecord = PipelineRecord,
    O extends PipelineRecord = PipelineRecord,
>(
    ctx: ExecutionContext,
    env: Env,
): PipelineTransformationEntrypoint<Env, I, O>
Type Parameters
- Env = unknown
- I extends PipelineRecord = PipelineRecord
- O extends PipelineRecord = PipelineRecord
Parameters
- ctx: ExecutionContext
- env: Env
Returns PipelineTransformationEntrypoint<Env, I, O>
- Defined in src/server/worker-configuration.d.ts:12685

Properties

`Protected`ctx

ctx: ExecutionContext

`Protected`env

env: Env

Methods

run

run(records: I[], metadata: PipelineBatchMetadata): Promise<O[]>
run receives an array of PipelineRecord which can be transformed and returned to the pipeline
Parameters
- records: I[]
  Incoming records from the pipeline to be transformed
- metadata: PipelineBatchMetadata
  Information about the specific pipeline calling the transformation entrypoint
Returns Promise<O[]>
A promise containing the transformed PipelineRecord array
- Defined in src/server/worker-configuration.d.ts:12693