Struct LoadBalanceSegment 

pub struct LoadBalanceSegment {
    pub destinations: Vec<OutcomeSegment>,
    pub strategy: LoadBalanceStrategy,
    pub round_robin_index: Arc<AtomicUsize>,
}

Outcome-aware LoadBalance segment. Holds N destinations + a strategy. On each call: strategy picks ONE destination (round-robin / failover / random / weighted), runs it. If chosen destination returns Completed, return Completed. If Stopped: return Stopped immediately (no failover — Stop is successful control flow). If Failed: strategy decides (failover retries next dest, others return Failed).

This differs from Multicast (which runs all branches) — LoadBalance picks exactly one. The parallel cancellation logic from T13/T15 does NOT apply.

Fields

destinations: Vec<OutcomeSegment>

strategy: LoadBalanceStrategy

round_robin_index: Arc<AtomicUsize>

Shared round-robin index for interior mutability across cloned segments.

Trait Implementations

impl Clone for LoadBalanceSegment

fn clone(&self) -> LoadBalanceSegment

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl OutcomePipeline for LoadBalanceSegment

fn clone_box(&self) -> Box<dyn OutcomePipeline>

Clone the segment into a new boxed instance. Required because Box<dyn OutcomePipeline> cannot directly derive Clone.

fn run<'a>( &'a mut self, exchange: Exchange, ) -> Pin<Box<dyn Future<Output = PipelineOutcome> + Send + 'a>>

Execute the segment against exchange, returning a PipelineOutcome.