Struct TransferExecutor 

pub struct TransferExecutor { /* private fields */ }

Executes a transfer plan with shared controls.

Implementations

impl TransferExecutor

pub fn new(controls: TransferControls) -> Result<Self>

pub async fn execute<T, F, Fut>( &self, plan: TransferPlan<T>, operation: F, ) -> TransferReport<T>

where T: Clone + Send + Sync + 'static, F: Fn(TransferCandidate<T>) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<u64>> + Send + 'static,

Execute candidates while bounding all in-flight work across the command.

pub async fn execute_with_cancellation<T, F, Fut>( &self, plan: TransferPlan<T>, cancellation: TransferCancellation, operation: F, ) -> TransferReport<T>

where T: Clone + Send + Sync + 'static, F: Fn(TransferCandidate<T>) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<u64>> + Send + 'static,

Execute candidates until completion, failure policy, or cooperative cancellation.

Work already in flight is allowed to settle so callers can await backend cleanup.

Trait Implementations

impl Clone for TransferExecutor

fn clone(&self) -> TransferExecutor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TransferExecutor

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

Formats the value using the given formatter.