Trait qiniu_sdk::prelude::ResumablePolicyProvider
source · pub trait ResumablePolicyProvider: DynClone + Debug + Sync + Send {
fn get_policy_from_size(
&self,
source_size: u64,
opts: GetPolicyOptions
) -> ResumablePolicy;
fn get_policy_from_reader(
&self,
reader: Box<dyn DynRead + 'a, Global>,
opts: GetPolicyOptions
) -> Result<(ResumablePolicy, Box<dyn DynRead + 'a, Global>), Error>;
fn get_policy_from_async_reader(
&self,
reader: Box<dyn DynAsyncRead + 'a, Global>,
opts: GetPolicyOptions
) -> Pin<Box<dyn Future<Output = Result<(ResumablePolicy, Box<dyn DynAsyncRead + 'a, Global>), Error>> + Send + 'a, Global>>;
}
Expand description
可恢复策略获取接口
Required Methods
sourcefn get_policy_from_size(
&self,
source_size: u64,
opts: GetPolicyOptions
) -> ResumablePolicy
fn get_policy_from_size(
&self,
source_size: u64,
opts: GetPolicyOptions
) -> ResumablePolicy
通过数据源大小获取可恢复策略
sourcefn get_policy_from_reader(
&self,
reader: Box<dyn DynRead + 'a, Global>,
opts: GetPolicyOptions
) -> Result<(ResumablePolicy, Box<dyn DynRead + 'a, Global>), Error>
fn get_policy_from_reader(
&self,
reader: Box<dyn DynRead + 'a, Global>,
opts: GetPolicyOptions
) -> Result<(ResumablePolicy, Box<dyn DynRead + 'a, Global>), Error>
sourcefn get_policy_from_async_reader(
&self,
reader: Box<dyn DynAsyncRead + 'a, Global>,
opts: GetPolicyOptions
) -> Pin<Box<dyn Future<Output = Result<(ResumablePolicy, Box<dyn DynAsyncRead + 'a, Global>), Error>> + Send + 'a, Global>>
fn get_policy_from_async_reader(
&self,
reader: Box<dyn DynAsyncRead + 'a, Global>,
opts: GetPolicyOptions
) -> Pin<Box<dyn Future<Output = Result<(ResumablePolicy, Box<dyn DynAsyncRead + 'a, Global>), Error>> + Send + 'a, Global>>
通过异步输入流获取可恢复策略
返回选择的可恢复策略,以及经过更新的异步输入流