Source

data class Source(val opId: OpId) : DraftStage

A source stage — the entry point of a Draft pipeline.

Represents named data living on peers (a collection, a named view, or any operation that produces elements to be processed downstream). Always CoordinationKind.Free: reading from a distributed collection is monotone.

Constructors

Link copied to clipboard
constructor(opId: OpId)

Properties

Link copied to clipboard

Whether this stage requires coordination to apply correctly.

Link copied to clipboard
open override val opId: OpId

The symbolic name of the operation this stage references. Code never moves; only names do.