Class InMemoryPipelineDestination<T>

Namespace

Pipelinez.Core.Destination

Assembly

Pipelinez.dll

Provides a minimal in-memory destination that simply logs received records.

public class InMemoryPipelineDestination<T> : PipelineDestination<T>, IPipelineDestination<T>, IFlowDestination<PipelineContainer<T>>, IPipelineExecutionConfigurable, IPipelineRetryConfigurable<T> where T : PipelineRecord

Type Parameters

T

Inheritance

object

PipelineDestination<T>

InMemoryPipelineDestination<T>

Implements

IPipelineDestination<T>

IFlowDestination<PipelineContainer<T>>

IPipelineExecutionConfigurable

IPipelineRetryConfigurable<T>

Inherited Members

PipelineDestination<T>.Logger

PipelineDestination<T>.Completion

PipelineDestination<T>.AsTargetBlock()

PipelineDestination<T>.StartAsync(CancellationTokenSource)

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

PipelineDestination<T>.ConfigureExecutionOptions(PipelineExecutionOptions)

PipelineDestination<T>.GetExecutionOptions()

PipelineDestination<T>.ConfigureRetryPolicy(PipelineRetryPolicy<T>)

PipelineDestination<T>.GetRetryPolicy()

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

InMemoryPipelineDestination()

Initializes a new in-memory destination.

public InMemoryPipelineDestination()

Methods

ExecuteAsync(T, CancellationToken)

Executes the destination logic for a successfully processed record.

protected override Task ExecuteAsync(T record, CancellationToken cancellationToken)

Parameters

record T

The record to write.

cancellationToken CancellationToken

The cancellation token for the execution.

Returns

Task

Initialize()

Provides an opportunity for the destination to initialize transport-specific state.

protected override void Initialize()