Class PipelineDistributedStatus

Namespace

Pipelinez.Core.Distributed

Assembly

Pipelinez.dll

Represents the distributed execution status exposed through pipeline status APIs.

public sealed class PipelineDistributedStatus

Inheritance

object

PipelineDistributedStatus

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

PipelineDistributedStatus(PipelineExecutionMode, string, string, IReadOnlyList<PipelinePartitionLease>?, IReadOnlyList<PipelinePartitionExecutionState>?)

Initializes a new distributed status snapshot.

public PipelineDistributedStatus(PipelineExecutionMode executionMode, string instanceId, string workerId, IReadOnlyList<PipelinePartitionLease>? ownedPartitions = null, IReadOnlyList<PipelinePartitionExecutionState>? partitionExecution = null)

Parameters

executionMode PipelineExecutionMode

instanceId string

workerId string

ownedPartitions IReadOnlyList<PipelinePartitionLease>

partitionExecution IReadOnlyList<PipelinePartitionExecutionState>

Properties

ExecutionMode

Gets the execution mode currently used by the pipeline.

public PipelineExecutionMode ExecutionMode { get; }

Property Value

PipelineExecutionMode

InstanceId

Gets the host instance identifier.

public string InstanceId { get; }

Property Value

string

OwnedPartitions

Gets the partitions currently owned by the worker.

public IReadOnlyList<PipelinePartitionLease> OwnedPartitions { get; }

Property Value

IReadOnlyList<PipelinePartitionLease>

PartitionExecution

Gets the current execution state of owned partitions.

public IReadOnlyList<PipelinePartitionExecutionState> PartitionExecution { get; }

Property Value

IReadOnlyList<PipelinePartitionExecutionState>

WorkerId

Gets the worker identifier.

public string WorkerId { get; }

Property Value

string