Class PipelinePerformanceSnapshot

Namespace

Pipelinez.Core.Performance

Assembly

Pipelinez.dll

Represents an aggregated performance snapshot for a running pipeline.

public sealed class PipelinePerformanceSnapshot

Inheritance

object

PipelinePerformanceSnapshot

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

PipelinePerformanceSnapshot(DateTimeOffset, TimeSpan, long, long, long, long, long, long, long, long, long, TimeSpan, long, int, double, TimeSpan, IReadOnlyList<PipelineComponentPerformanceSnapshot>)

Initializes a new pipeline performance snapshot.

public PipelinePerformanceSnapshot(DateTimeOffset startedAtUtc, TimeSpan elapsed, long totalRecordsPublished, long totalRecordsCompleted, long totalRecordsFaulted, long totalRetryCount, long successfulRetryRecoveries, long retryExhaustions, long totalDeadLetteredCount, long totalDeadLetterFailureCount, long totalPublishWaitCount, TimeSpan averagePublishWaitDuration, long totalPublishRejectedCount, int peakBufferedCount, double recordsPerSecond, TimeSpan averageEndToEndLatency, IReadOnlyList<PipelineComponentPerformanceSnapshot> components)

Parameters

startedAtUtc DateTimeOffset

elapsed TimeSpan

totalRecordsPublished long

totalRecordsCompleted long

totalRecordsFaulted long

totalRetryCount long

successfulRetryRecoveries long

retryExhaustions long

totalDeadLetteredCount long

totalDeadLetterFailureCount long

totalPublishWaitCount long

averagePublishWaitDuration TimeSpan

totalPublishRejectedCount long

peakBufferedCount int

recordsPerSecond double

averageEndToEndLatency TimeSpan

components IReadOnlyList<PipelineComponentPerformanceSnapshot>

Properties

AverageEndToEndLatency

Gets the average end-to-end latency for completed records.

public TimeSpan AverageEndToEndLatency { get; }

Property Value

TimeSpan

AveragePublishWaitDuration

Gets the average duration spent waiting for capacity during publish.

public TimeSpan AveragePublishWaitDuration { get; }

Property Value

TimeSpan

Components

Gets the component-level performance snapshots.

public IReadOnlyList<PipelineComponentPerformanceSnapshot> Components { get; }

Property Value

IReadOnlyList<PipelineComponentPerformanceSnapshot>

Elapsed

Gets the elapsed time covered by the snapshot.

public TimeSpan Elapsed { get; }

Property Value

TimeSpan

PeakBufferedCount

Gets the peak buffered record count observed across the pipeline.

public int PeakBufferedCount { get; }

Property Value

int

RecordsPerSecond

Gets the current calculated records-per-second rate for the pipeline.

public double RecordsPerSecond { get; }

Property Value

double

RetryExhaustions

Gets the number of times retries were exhausted.

public long RetryExhaustions { get; }

Property Value

long

StartedAtUtc

Gets the time performance collection started.

public DateTimeOffset StartedAtUtc { get; }

Property Value

DateTimeOffset

SuccessfulRetryRecoveries

Gets the number of times retry recovered a record successfully.

public long SuccessfulRetryRecoveries { get; }

Property Value

long

TotalDeadLetterFailureCount

Gets the total number of dead-letter write failures.

public long TotalDeadLetterFailureCount { get; }

Property Value

long

TotalDeadLetteredCount

Gets the total number of dead-lettered records.

public long TotalDeadLetteredCount { get; }

Property Value

long

TotalPublishRejectedCount

Gets the total number of rejected publish calls.

public long TotalPublishRejectedCount { get; }

Property Value

long

TotalPublishWaitCount

Gets the total number of publish calls that waited for capacity.

public long TotalPublishWaitCount { get; }

Property Value

long

TotalRecordsCompleted

Gets the total number of records completed successfully.

public long TotalRecordsCompleted { get; }

Property Value

long

TotalRecordsFaulted

Gets the total number of faulted records observed by the pipeline.

public long TotalRecordsFaulted { get; }

Property Value

long

TotalRecordsPublished

Gets the total number of records published into the pipeline.

public long TotalRecordsPublished { get; }

Property Value

long

TotalRetryCount

Gets the total number of retry attempts performed.

public long TotalRetryCount { get; }

Property Value

long