Trait ConcurrencyProvider

pub trait ConcurrencyProvider:
    DynClone
    + Debug
    + Sync
    + Send {
    // Required methods
    fn concurrency(&self) -> Concurrency;
    fn feedback(&self, feedback: ConcurrencyProviderFeedback<'_>);
}

并发数获取接口

获取分片上传时的并发数

Required Methods

fn concurrency(&self) -> Concurrency

获取并发数

fn feedback(&self, feedback: ConcurrencyProviderFeedback<'_>)

反馈并发数结果

Trait Implementations

impl<'clone> Clone for Box<dyn ConcurrencyProvider + 'clone>

fn clone(&self) -> Box<dyn ConcurrencyProvider + 'clone>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<'clone> Clone for Box<dyn ConcurrencyProvider + Send + 'clone>

fn clone(&self) -> Box<dyn ConcurrencyProvider + Send + 'clone>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<'clone> Clone for Box<dyn ConcurrencyProvider + Sync + Send + 'clone>

fn clone(&self) -> Box<dyn ConcurrencyProvider + Sync + Send + 'clone>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<'clone> Clone for Box<dyn ConcurrencyProvider + Sync + 'clone>

fn clone(&self) -> Box<dyn ConcurrencyProvider + Sync + 'clone>

Returns a copy of the value.

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

Performs copy-assignment from source.

Implementations on Foreign Types

impl<'a, T> ConcurrencyProvider for &'a T

where T: 'a + ConcurrencyProvider + ?Sized, &'a T: DynClone + Debug + Sync + Send,

fn concurrency(&self) -> Concurrency

fn feedback(&self, feedback: ConcurrencyProviderFeedback<'_>)

impl<'a, T> ConcurrencyProvider for &'a mut T

where T: 'a + ConcurrencyProvider + ?Sized, &'a mut T: DynClone + Debug + Sync + Send,

fn concurrency(&self) -> Concurrency

fn feedback(&self, feedback: ConcurrencyProviderFeedback<'_>)

impl<T> ConcurrencyProvider for Box<T>

where T: ConcurrencyProvider + ?Sized, Box<T>: DynClone + Debug + Sync + Send,

fn concurrency(&self) -> Concurrency

fn feedback(&self, feedback: ConcurrencyProviderFeedback<'_>)

impl<T> ConcurrencyProvider for Rc<T>

where T: ConcurrencyProvider + ?Sized, Rc<T>: DynClone + Debug + Sync + Send,

fn concurrency(&self) -> Concurrency

fn feedback(&self, feedback: ConcurrencyProviderFeedback<'_>)

impl<T> ConcurrencyProvider for Arc<T>

where T: ConcurrencyProvider + ?Sized, Arc<T>: DynClone + Debug + Sync + Send,

fn concurrency(&self) -> Concurrency

fn feedback(&self, feedback: ConcurrencyProviderFeedback<'_>)

Implementors

impl ConcurrencyProvider for FixedConcurrencyProvider