Struct FanoutScheduler 

pub struct FanoutScheduler { /* private fields */ }

Cancellation-aware stable-order bounded fanout scheduler.

Implementations

impl FanoutScheduler

pub const fn new(policy: FanoutPolicy) -> Self

Creates a scheduler from validated bounds.

pub async fn run<T, E, F, Fut>( &self, targets: Vec<HostRecord>, cancellation: CancellationToken, operation: F, ) -> FanoutReport<T, E>

where T: Send, E: Send, F: Fn(HostRecord, CancellationToken) -> Fut + Send + Sync, Fut: Future<Output = Result<T, E>> + Send,

Executes one operation for every target with bounded concurrency.

Returned outcomes are sorted back into the caller’s target order even when faster targets complete first. Pending targets become cancelled after the shared token is cancelled instead of disappearing.

pub async fn run_with_payload<P, T, E, F, Fut>( &self, targets: Vec<(HostRecord, P)>, cancellation: CancellationToken, operation: F, ) -> FanoutReport<T, E>

where P: Send, T: Send, E: Send, F: Fn(HostRecord, P, CancellationToken) -> Fut + Send + Sync, Fut: Future<Output = Result<T, E>> + Send,

Executes one operation for every host/payload pair with bounded concurrency.

Payloads remain paired with their original target index, allowing callers to fan out distinct requests to the same host without key-based races.

Trait Implementations

impl Clone for FanoutScheduler

fn clone(&self) -> FanoutScheduler

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FanoutScheduler

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Copy for FanoutScheduler