Struct WireTapService 

pub struct WireTapService { /* private fields */ }

Implementations

impl WireTapService

pub fn new(tap_endpoint: BoxProcessor) -> Self

Create a new WireTapService with default (bounded-20) concurrency.

pub fn with_config(tap_endpoint: BoxProcessor, config: WireTapConfig) -> Self

Create a new WireTapService from a WireTapConfig.

impl WireTapService

pub fn lifecycle(&self) -> Arc<dyn StepLifecycle>

Obtain a shared lifecycle handle for this service’s admission gate and task tracker. Callers can invoke StepLifecycle::shutdown on the returned handle for graceful-drain-then-abort teardown.

Trait Implementations

impl Clone for WireTapService

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Service<Exchange> for WireTapService

fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Always ready (ADR-0019): the main route never blocks on tap readiness. Tap endpoint readiness is driven inside [run_tap] on the fire-and- forgetget path; a tap readiness error is logged and suppressed, never propagated to the main exchange.

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 call(&mut self, exchange: Exchange) -> Self::Future

Process the request and return the response asynchronously.