Interface IBatchedPipelineDestination<T>

Namespace

Pipelinez.Core.Destination

Assembly

Pipelinez.dll

Defines a destination that can process groups of pipeline containers in a single batch operation.

public interface IBatchedPipelineDestination<T> : IPipelineDestination<T>, IFlowDestination<PipelineContainer<T>> where T : PipelineRecord

Type Parameters

T

The pipeline record type written by the destination.

Inherited Members

IPipelineDestination<T>.StartAsync(CancellationTokenSource)

IPipelineDestination<T>.Completion

IPipelineDestination<T>.Initialize(Pipeline<T>)

IFlowDestination<PipelineContainer<T>>.AsTargetBlock()

Methods

ExecuteBatchAsync(IReadOnlyList<PipelineContainer<T>>, CancellationToken)

Executes a batch of records as a single destination operation.

Task ExecuteBatchAsync(IReadOnlyList<PipelineContainer<T>> batch, CancellationToken cancellationToken)

Parameters

batch IReadOnlyList<PipelineContainer<T>>

The batch of pipeline containers to process.

cancellationToken CancellationToken

A token used to cancel the batch operation.

Returns

Task