Namespace Pipelinez.Core.Source

Classes

InMemoryPipelineSource<T>

Provides a minimal in-memory source for tests and simple manual publication scenarios.

PipelineSourceBase<T>

Provides a base implementation for pipeline sources backed by a Dataflow buffer.

Interfaces

IDistributedPipelineSource<T>

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

IPipelineSource<T>

Defines a pipeline source that can publish records into the pipeline runtime.