Class PipelinePartitionExecutionState

Namespace

Pipelinez.Core.Distributed

Assembly

Pipelinez.dll

Describes the current execution state of a single owned partition.

public sealed class PipelinePartitionExecutionState

Inheritance

object

PipelinePartitionExecutionState

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

PipelinePartitionExecutionState(string, string, int?, bool, bool, int, long?)

Initializes a new partition execution state snapshot.

public PipelinePartitionExecutionState(string leaseId, string partitionKey, int? partitionId, bool isAssigned, bool isDraining, int inFlightCount, long? highestCompletedOffset)

Parameters

leaseId string

partitionKey string

partitionId int?

isAssigned bool

isDraining bool

inFlightCount int

highestCompletedOffset long?

Properties

HighestCompletedOffset

Gets the highest completed offset observed for the partition, if one exists.

public long? HighestCompletedOffset { get; }

Property Value

long?

InFlightCount

Gets the number of in-flight records for the partition.

public int InFlightCount { get; }

Property Value

int

IsAssigned

Gets a value indicating whether the partition is currently assigned to this worker.

public bool IsAssigned { get; }

Property Value

bool

IsDraining

Gets a value indicating whether the partition is draining during rebalance or shutdown.

public bool IsDraining { get; }

Property Value

bool

LeaseId

Gets the logical lease identifier.

public string LeaseId { get; }

Property Value

string

PartitionId

Gets the numeric partition identifier, if one exists.

public int? PartitionId { get; }

Property Value

int?

PartitionKey

Gets the logical partition key.

public string PartitionKey { get; }

Property Value

string