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,
    ) -> Result<(ResumablePolicy, Box<dyn DynRead + 'a>), Error>;
    fn get_policy_from_async_reader<'a>(
        &self,
        reader: Box<dyn DynAsyncRead + 'a>,
        opts: GetPolicyOptions,
    ) -> Pin<Box<dyn Future<Output = Result<(ResumablePolicy, Box<dyn DynAsyncRead + 'a>), Error>> + Send + '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, ) -> Result<(ResumablePolicy, Box<dyn DynRead + 'a>), Error>

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

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

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

fn get_policy_from_async_reader<'a>( &self, reader: Box<dyn DynAsyncRead + 'a>, opts: GetPolicyOptions, ) -> Pin<Box<dyn Future<Output = Result<(ResumablePolicy, Box<dyn DynAsyncRead + 'a>), Error>> + Send + 'a>>

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

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

Implementations on Foreign Types

impl<'b, T> ResumablePolicyProvider for &'b T

where T: 'b + ResumablePolicyProvider + ?Sized, &'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, ) -> Result<(ResumablePolicy, Box<dyn DynRead + 'a>), Error>

fn get_policy_from_async_reader<'a>( &self, reader: Box<dyn DynAsyncRead + 'a>, opts: GetPolicyOptions, ) -> Pin<Box<dyn Future<Output = Result<(ResumablePolicy, Box<dyn DynAsyncRead + 'a>), Error>> + Send + 'a>>

impl<'b, T> ResumablePolicyProvider for &'b mut T

where T: 'b + ResumablePolicyProvider + ?Sized, &'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, ) -> Result<(ResumablePolicy, Box<dyn DynRead + 'a>), Error>

fn get_policy_from_async_reader<'a>( &self, reader: Box<dyn DynAsyncRead + 'a>, opts: GetPolicyOptions, ) -> Pin<Box<dyn Future<Output = Result<(ResumablePolicy, Box<dyn DynAsyncRead + 'a>), Error>> + Send + 'a>>

impl<T> ResumablePolicyProvider for Box<T>

where T: ResumablePolicyProvider + ?Sized, 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, ) -> Result<(ResumablePolicy, Box<dyn DynRead + 'a>), Error>

fn get_policy_from_async_reader<'a>( &self, reader: Box<dyn DynAsyncRead + 'a>, opts: GetPolicyOptions, ) -> Pin<Box<dyn Future<Output = Result<(ResumablePolicy, Box<dyn DynAsyncRead + 'a>), Error>> + Send + 'a>>

impl<T> ResumablePolicyProvider for Rc<T>

where T: ResumablePolicyProvider + ?Sized, 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, ) -> Result<(ResumablePolicy, Box<dyn DynRead + 'a>), Error>

fn get_policy_from_async_reader<'a>( &self, reader: Box<dyn DynAsyncRead + 'a>, opts: GetPolicyOptions, ) -> Pin<Box<dyn Future<Output = Result<(ResumablePolicy, Box<dyn DynAsyncRead + 'a>), Error>> + Send + 'a>>

impl<T> ResumablePolicyProvider for Arc<T>

where T: ResumablePolicyProvider + ?Sized, 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, ) -> Result<(ResumablePolicy, Box<dyn DynRead + 'a>), Error>

fn get_policy_from_async_reader<'a>( &self, reader: Box<dyn DynAsyncRead + 'a>, opts: GetPolicyOptions, ) -> Pin<Box<dyn Future<Output = Result<(ResumablePolicy, Box<dyn DynAsyncRead + 'a>), Error>> + Send + 'a>>

Implementors

impl ResumablePolicyProvider for AlwaysMultiParts

impl ResumablePolicyProvider for AlwaysSinglePart

impl ResumablePolicyProvider for FixedThresholdResumablePolicy

impl<P> ResumablePolicyProvider for MultiplePartitionsResumablePolicyProvider<P>

where P: DataPartitionProvider + Clone,