Struct RouteChannelService 

pub struct RouteChannelService { /* private fields */ }

Route channel with explicit security and circuit-breaker gates.

Gate order: Security → CB(before_call) → Pipeline → CB(after_result). Errors from Security/CB gates go to handler.handle_boundary. Errors from Pipeline go through the injected handler’s retry/handle_step. Pipeline Propagate returns Err — passed through to upstream.

Implementations

impl RouteChannelService

pub fn new( handler: Arc<dyn RouteErrorHandler>, security: Option<BoxProcessor>, cb_gate: Option<CircuitBreakerGate>, pipeline: BoxProcessor, ) -> Self

Trait Implementations

impl Clone for RouteChannelService

fn clone(&self) -> RouteChannelService

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Service<Exchange> for RouteChannelService

type Response = Exchange

Responses given by the service.

type Error = CamelError

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<Exchange, CamelError>> + Send>>

The future response value.

fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), CamelError>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, exchange: Exchange) -> Self::Future

Process the request and return the response asynchronously.