Class PipelineRecordDistributionContext

Namespace

Pipelinez.Core.Distributed

Assembly

Pipelinez.dll

Captures the distributed execution context associated with a single record.

public sealed class PipelineRecordDistributionContext

Inheritance

object

PipelineRecordDistributionContext

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

PipelineRecordDistributionContext(string, string, string?, string?, string?, int?, long?)

Initializes a new record distribution context.

public PipelineRecordDistributionContext(string instanceId, string workerId, string? transportName, string? leaseId, string? partitionKey, int? partitionId, long? offset)

Parameters

instanceId string

workerId string

transportName string

leaseId string

partitionKey string

partitionId int?

offset long?

Properties

InstanceId

Gets the host instance identifier that processed the record.

public string InstanceId { get; }

Property Value

string

LeaseId

Gets the logical lease identifier, if the source provided one.

public string? LeaseId { get; }

Property Value

string

Offset

Gets the transport offset, if the source provided one.

public long? Offset { get; }

Property Value

long?

PartitionId

Gets the numeric partition identifier, if the source provided one.

public int? PartitionId { get; }

Property Value

int?

PartitionKey

Gets the logical partition key, if the source provided one.

public string? PartitionKey { get; }

Property Value

string

TransportName

Gets the transport name, if the source provided one.

public string? TransportName { get; }

Property Value

string

WorkerId

Gets the worker identifier that processed the record.

public string WorkerId { get; }

Property Value

string