Struct MulticastService 

pub struct MulticastService { /* private fields */ }

Tower Service implementing the Multicast EIP.

DoS bound (R3-L4): fan-out is bounded by the static endpoint list (operator-configured at route build, not attacker-controlled). In parallel mode, parallel_limit defaults to endpoints.len() so the code path always carries an explicit concurrency bound.

Sends a message to multiple endpoints, processing each independently, and then aggregating the results.

Supports both sequential and parallel processing modes, configurable via MulticastConfig::parallel. When parallel mode is enabled, all endpoints are invoked concurrently with optional concurrency limiting via MulticastConfig::parallel_limit.

Implementations

impl MulticastService

pub fn new( endpoints: Vec<BoxProcessor>, config: MulticastConfig, ) -> Result<Self, CamelError>

Create a new MulticastService from a list of endpoints and a MulticastConfig.

pub fn config(&self) -> &MulticastConfig

Borrow the effective config (post-normalization).

Trait Implementations

impl Clone for MulticastService

fn clone(&self) -> MulticastService

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Service<Exchange> for MulticastService

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<(), Self::Error>>

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.