Trait qiniu_upload_manager::ResumablePolicyProvider

pub trait ResumablePolicyProvider: DynClone + Debug + Sync + Send {
    fn get_policy_from_size(
        &self,
        source_size: u64,
        opts: GetPolicyOptions
    ) -> ResumablePolicy;
    fn get_policy_from_reader<'a>(
        &self,
        reader: Box<dyn DynRead + 'a>,
        opts: GetPolicyOptions
    ) -> IoResult<(ResumablePolicy, Box<dyn DynRead + 'a>)>;
    fn get_policy_from_async_reader<'a>(
        &self,
        reader: Box<dyn DynAsyncRead + 'a>,
        opts: GetPolicyOptions
    ) -> BoxFuture<'a, IoResult<(ResumablePolicy, Box<dyn DynAsyncRead + 'a>)>>;
}

可恢复策略获取接口

Required Methods

fn get_policy_from_size(
    &self,
    source_size: u64,
    opts: GetPolicyOptions
) -> ResumablePolicy

通过数据源大小获取可恢复策略

fn get_policy_from_reader<'a>(
    &self,
    reader: Box<dyn DynRead + 'a>,
    opts: GetPolicyOptions
) -> IoResult<(ResumablePolicy, Box<dyn DynRead + 'a>)>

通过输入流获取可恢复策略

返回选择的可恢复策略，以及经过更新的输入流

该方法的异步版本为 Self::get_policy_from_async_reader。

fn get_policy_from_async_reader<'a>(
    &self,
    reader: Box<dyn DynAsyncRead + 'a>,
    opts: GetPolicyOptions
) -> BoxFuture<'a, IoResult<(ResumablePolicy, Box<dyn DynAsyncRead + 'a>)>>

Available on crate feature async only.

通过异步输入流获取可恢复策略

返回选择的可恢复策略，以及经过更新的异步输入流

Trait Implementations

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

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

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

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

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

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

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

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

Implementations on Foreign Types

impl<'b, T: 'b + ResumablePolicyProvider + ?Sized> ResumablePolicyProvider for &'b Twhere
    &'b T: DynClone + Debug + Sync + Send,

fn get_policy_from_size(
    &self,
    source_size: u64,
    opts: GetPolicyOptions
) -> ResumablePolicy

fn get_policy_from_reader<'a>(
    &self,
    reader: Box<dyn DynRead + 'a>,
    opts: GetPolicyOptions
) -> IoResult<(ResumablePolicy, Box<dyn DynRead + 'a>)>

fn get_policy_from_async_reader<'a>(
    &self,
    reader: Box<dyn DynAsyncRead + 'a>,
    opts: GetPolicyOptions
) -> BoxFuture<'a, IoResult<(ResumablePolicy, Box<dyn DynAsyncRead + 'a>)>>

Available on crate feature async only.

impl<'b, T: 'b + ResumablePolicyProvider + ?Sized> ResumablePolicyProvider for &'b mut Twhere
    &'b mut T: DynClone + Debug + Sync + Send,

fn get_policy_from_size(
    &self,
    source_size: u64,
    opts: GetPolicyOptions
) -> ResumablePolicy

fn get_policy_from_reader<'a>(
    &self,
    reader: Box<dyn DynRead + 'a>,
    opts: GetPolicyOptions
) -> IoResult<(ResumablePolicy, Box<dyn DynRead + 'a>)>

fn get_policy_from_async_reader<'a>(
    &self,
    reader: Box<dyn DynAsyncRead + 'a>,
    opts: GetPolicyOptions
) -> BoxFuture<'a, IoResult<(ResumablePolicy, Box<dyn DynAsyncRead + 'a>)>>

Available on crate feature async only.

impl<T: ResumablePolicyProvider + ?Sized> ResumablePolicyProvider for Box<T>where
    Box<T>: DynClone + Debug + Sync + Send,

fn get_policy_from_size(
    &self,
    source_size: u64,
    opts: GetPolicyOptions
) -> ResumablePolicy

fn get_policy_from_reader<'a>(
    &self,
    reader: Box<dyn DynRead + 'a>,
    opts: GetPolicyOptions
) -> IoResult<(ResumablePolicy, Box<dyn DynRead + 'a>)>

fn get_policy_from_async_reader<'a>(
    &self,
    reader: Box<dyn DynAsyncRead + 'a>,
    opts: GetPolicyOptions
) -> BoxFuture<'a, IoResult<(ResumablePolicy, Box<dyn DynAsyncRead + 'a>)>>

Available on crate feature async only.

impl<T: ResumablePolicyProvider + ?Sized> ResumablePolicyProvider for Rc<T>where
    Rc<T>: DynClone + Debug + Sync + Send,

fn get_policy_from_size(
    &self,
    source_size: u64,
    opts: GetPolicyOptions
) -> ResumablePolicy

fn get_policy_from_reader<'a>(
    &self,
    reader: Box<dyn DynRead + 'a>,
    opts: GetPolicyOptions
) -> IoResult<(ResumablePolicy, Box<dyn DynRead + 'a>)>

fn get_policy_from_async_reader<'a>(
    &self,
    reader: Box<dyn DynAsyncRead + 'a>,
    opts: GetPolicyOptions
) -> BoxFuture<'a, IoResult<(ResumablePolicy, Box<dyn DynAsyncRead + 'a>)>>

Available on crate feature async only.

impl<T: ResumablePolicyProvider + ?Sized> ResumablePolicyProvider for Arc<T>where
    Arc<T>: DynClone + Debug + Sync + Send,

fn get_policy_from_size(
    &self,
    source_size: u64,
    opts: GetPolicyOptions
) -> ResumablePolicy

fn get_policy_from_reader<'a>(
    &self,
    reader: Box<dyn DynRead + 'a>,
    opts: GetPolicyOptions
) -> IoResult<(ResumablePolicy, Box<dyn DynRead + 'a>)>

fn get_policy_from_async_reader<'a>(
    &self,
    reader: Box<dyn DynAsyncRead + 'a>,
    opts: GetPolicyOptions
) -> BoxFuture<'a, IoResult<(ResumablePolicy, Box<dyn DynAsyncRead + 'a>)>>

Available on crate feature async only.

Implementors

impl ResumablePolicyProvider for AlwaysMultiParts

impl ResumablePolicyProvider for AlwaysSinglePart

impl ResumablePolicyProvider for FixedThresholdResumablePolicy

impl<P: DataPartitionProvider + Clone> ResumablePolicyProvider for MultiplePartitionsResumablePolicyProvider<P>