Struct ThrottleSegment 

pub struct ThrottleSegment {
    pub config: ThrottlerConfig,
    pub limiter: Arc<Mutex<RateLimiter>>,
    pub body: OutcomeSegment,
}

Outcome-aware throttle segment (ADR-0025).

Wraps a ThrottlerConfig + shared RateLimiter + child sub-pipeline body. Unlike ThrottlerService (which operates at the Tower layer), ThrottleSegment correctly propagates PipelineOutcome::Stopped / Failed from the body.

Fields

config: ThrottlerConfig

limiter: Arc<Mutex<RateLimiter>>

body: OutcomeSegment

Implementations

impl ThrottleSegment

pub fn new(config: ThrottlerConfig, body: OutcomeSegment) -> Self

Construct a throttle segment. Panics if invariants are violated. Prefer try_new.

pub fn try_new( config: ThrottlerConfig, body: OutcomeSegment, ) -> Result<Self, CamelError>

Fallible constructor. Same validation as ThrottlerService::try_new.

Trait Implementations

impl Clone for ThrottleSegment

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl OutcomePipeline for ThrottleSegment

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.