Interface IDistributedPipelineSource<T>

Namespace

Pipelinez.Core.Source

Assembly

Pipelinez.dll

Defines a source that can report distributed ownership and partition execution state.

public interface IDistributedPipelineSource<T> : IPipelineSource<T>, IFlowSource<PipelineContainer<T>> where T : PipelineRecord

Type Parameters

T

The pipeline record type produced by the source.

Inherited Members

IPipelineSource<T>.StartAsync(CancellationTokenSource)

IPipelineSource<T>.PublishAsync(T)

IPipelineSource<T>.PublishAsync(T, PipelinePublishOptions)

IPipelineSource<T>.PublishAsync(T, MetadataCollection)

IPipelineSource<T>.PublishAsync(T, MetadataCollection, PipelinePublishOptions)

IPipelineSource<T>.Complete()

IPipelineSource<T>.Completion

IPipelineSource<T>.Initialize(Pipeline<T>)

IPipelineSource<T>.OnPipelineContainerComplete(object, PipelineContainerCompletedEventHandlerArgs<PipelineContainer<T>>)

IFlowSource<PipelineContainer<T>>.ConnectTo(IFlowDestination<PipelineContainer<T>>, DataflowLinkOptions)

Properties

SupportsDistributedExecution

Gets a value indicating whether the source supports distributed execution.

bool SupportsDistributedExecution { get; }

Property Value

bool

TransportName

Gets the transport name reported in distributed metadata.

string TransportName { get; }

Property Value

string

Methods

GetOwnedPartitions()

Gets the partitions currently owned by the source.

IReadOnlyList<PipelinePartitionLease> GetOwnedPartitions()

Returns

IReadOnlyList<PipelinePartitionLease>

The owned partition leases.

GetPartitionExecutionStates()

Gets the current execution state for owned partitions.

IReadOnlyList<PipelinePartitionExecutionState> GetPartitionExecutionStates()

Returns

IReadOnlyList<PipelinePartitionExecutionState>

The partition execution state snapshots.