Trait ResumablePolicyProvider

pub trait ResumablePolicyProvider:
    DynClone
    + Debug
    + Sync
    + Send {
    // 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>)>;
    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.

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

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

Implementations on Foreign Types

impl<'b, T: 'b + ResumablePolicyProvider + ?Sized> ResumablePolicyProvider for &'b T

where &'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 T

where &'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>