Class PipelineRuntimeContext

Namespace

Pipelinez.Core.Distributed

Assembly

Pipelinez.dll

Describes the current runtime identity and owned work for a running pipeline.

public sealed class PipelineRuntimeContext

Inheritance

object

PipelineRuntimeContext

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

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

Initializes a new runtime context snapshot.

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

Parameters

pipelineName string

executionMode PipelineExecutionMode

instanceId string

workerId string

ownedPartitions IReadOnlyList<PipelinePartitionLease>

partitionExecution IReadOnlyList<PipelinePartitionExecutionState>

Properties

ExecutionMode

Gets the configured execution mode.

public PipelineExecutionMode ExecutionMode { get; }

Property Value

PipelineExecutionMode

InstanceId

Gets the current 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>

PipelineName

Gets the logical pipeline name.

public string PipelineName { get; }

Property Value

string

WorkerId

Gets the current worker identifier.

public string WorkerId { get; }

Property Value

string