Class PipelineContainer<T>

Namespace

Pipelinez.Core.Record

Assembly

Pipelinez.dll

Wraps a pipeline record with metadata, fault state, and execution history while it moves through the pipeline.

public sealed class PipelineContainer<T> where T : PipelineRecord

Type Parameters

T

The pipeline record type carried by the container.

Inheritance

object

PipelineContainer<T>

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

PipelineContainer(T)

Initializes a new container for the supplied record with an empty metadata collection.

public PipelineContainer(T record)

Parameters

record T

The record to wrap.

PipelineContainer(T, MetadataCollection)

Initializes a new container for the supplied record and metadata.

public PipelineContainer(T record, MetadataCollection metadata)

Parameters

record T

The record to wrap.

metadata MetadataCollection

The metadata associated with the record.

Properties

CreatedAtUtc

Gets the time the container was created.

public DateTimeOffset CreatedAtUtc { get; }

Property Value

DateTimeOffset

Fault

Gets the fault state recorded for the container, if any.

public PipelineFaultState? Fault { get; }

Property Value

PipelineFaultState

HasFault

Gets a value indicating whether the container has faulted.

public bool HasFault { get; }

Property Value

bool

Metadata

Gets the metadata associated with the record.

public MetadataCollection Metadata { get; }

Property Value

MetadataCollection

Record

Gets or sets the record carried by the container.

public T Record { get; set; }

Property Value

T

RetryHistory

Gets the ordered retry history recorded for the container.

public IList<PipelineRetryAttempt> RetryHistory { get; }

Property Value

IList<PipelineRetryAttempt>

SegmentHistory

Gets the ordered execution history recorded for pipeline segments.

public IList<PipelineSegmentExecution> SegmentHistory { get; }

Property Value

IList<PipelineSegmentExecution>

Methods

AddRetryAttempt(PipelineRetryAttempt)

Adds a retry attempt entry to the container history.

public void AddRetryAttempt(PipelineRetryAttempt retryAttempt)

Parameters

retryAttempt PipelineRetryAttempt

The retry attempt to add.

AddSegmentExecution(PipelineSegmentExecution)

Adds a segment execution entry to the container history.

public void AddSegmentExecution(PipelineSegmentExecution segmentExecution)

Parameters

segmentExecution PipelineSegmentExecution

The execution record to add.

MarkFaulted(PipelineFaultState)

Marks the container as faulted.

public void MarkFaulted(PipelineFaultState fault)

Parameters

fault PipelineFaultState

The fault state to record.