Struct SingleRingBuilder 

pub struct SingleRingBuilder { /* private fields */ }

Builder for ExecutionModelV1::SingleRing specs.

This is intentionally small: it helps construct valid v1 specs without macros.

Implementations

impl SingleRingBuilder

pub fn new() -> Self

Create a new builder with v1 defaults.

pub fn shards(&mut self, shards: u32) -> &mut Self

Set the number of PerKey shards.

pub fn ordering(&mut self, ordering: OrderingV1) -> &mut Self

Set requested ordering semantics.

pub fn producer(&mut self, producer: SingleRingProducerV1) -> &mut Self

Set requested producer model.

pub fn scheduling(&mut self, scheduling: SingleRingSchedulingV1) -> &mut Self

Set requested scheduling model.

pub fn shard_key(&mut self, shard_key: ShardKeyV1) -> &mut Self

Set the shard key extractor.

pub fn push_source_stage(&mut self, op: StageOpV1) -> Result<u32, SpecError>

Add a stage that depends directly on the producer cursor.

pub fn push_stage( &mut self, op: StageOpV1, depends_on: &[u32], ) -> Result<u32, SpecError>

Add a stage with explicit dependencies.

depends_on contains stage indices; each dependency must reference a stage that has already been added.

pub fn build(self) -> Result<PipelineSpecV1, SpecError>

Build the full PipelineSpecV1.

Trait Implementations

impl Default for SingleRingBuilder

Available on crate feature alloc only.

fn default() -> Self

Returns the “default value” for a type.