Trait qiniu_sdk::prelude::DataSource

pub trait DataSource<A>: Debug + Sync + Send where
    A: Digest, {
    fn slice(&self, size: PartSize) -> Result<Option<DataSourceReader>, Error>;
    fn async_slice(
        &self, 
        size: PartSize
    ) -> Pin<Box<dyn Future<Output = Result<Option<AsyncDataSourceReader>, Error>> + Send, Global>>;
    fn total_size(&self) -> Result<Option<u64>, Error>;

    fn source_key(&self) -> Result<Option<SourceKey<A>>, Error> { ... }
    fn async_source_key(
        &self
    ) -> Pin<Box<dyn Future<Output = Result<Option<SourceKey<A>>, Error>> + Send, Global>> { ... }
    fn async_total_size(
        &self
    ) -> Pin<Box<dyn Future<Output = Result<Option<u64>, Error>> + Send, Global>> { ... }
}

数据源接口

提供上传所用的数据源

Required Methods

fn slice(&self, size: PartSize) -> Result<Option<DataSourceReader>, Error>

数据源切片

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

fn async_slice(
    &self,
    size: PartSize
) -> Pin<Box<dyn Future<Output = Result<Option<AsyncDataSourceReader>, Error>> + Send, Global>>

异步数据源切片

fn total_size(&self) -> Result<Option<u64>, Error>

获取数据源大小

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

Provided Methods

fn source_key(&self) -> Result<Option<SourceKey<A>>, Error>

获取数据源 KEY

用于区分不同的数据源

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

fn async_source_key(
    &self
) -> Pin<Box<dyn Future<Output = Result<Option<SourceKey<A>>, Error>> + Send, Global>>

异步获取数据源 KEY

用于区分不同的数据源

fn async_total_size(
    &self
) -> Pin<Box<dyn Future<Output = Result<Option<u64>, Error>> + Send, Global>>

异步获取数据源大小

Implementations on Foreign Types

impl<A, T> DataSource<A> for Arc<T> where
    A: Digest,
    T: DataSource<A> + ?Sized,
    Arc<T>: Debug,
    Arc<T>: Sync,
    Arc<T>: Send, 

fn slice(&self, size: PartSize) -> Result<Option<DataSourceReader>, Error>

数据源切片

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

fn async_slice(
    &self,
    size: PartSize
) -> Pin<Box<dyn Future<Output = Result<Option<AsyncDataSourceReader>, Error>> + Send, Global>>

异步数据源切片

fn source_key(&self) -> Result<Option<SourceKey<A>>, Error>

获取数据源 KEY

用于区分不同的数据源

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

fn async_source_key(
    &self
) -> Pin<Box<dyn Future<Output = Result<Option<SourceKey<A>>, Error>> + Send, Global>>

异步获取数据源 KEY

用于区分不同的数据源

fn total_size(&self) -> Result<Option<u64>, Error>

获取数据源大小

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

fn async_total_size(
    &self
) -> Pin<Box<dyn Future<Output = Result<Option<u64>, Error>> + Send, Global>>

异步获取数据源大小

impl<'a, A, T> DataSource<A> for &'a T where
    A: Digest,
    T: 'a + DataSource<A> + ?Sized,
    &'a T: Debug,
    &'a T: Sync,
    &'a T: Send, 

fn slice(&self, size: PartSize) -> Result<Option<DataSourceReader>, Error>

数据源切片

该方法的异步版本为 [Self::async_slice]。

fn async_slice(
    &self,
    size: PartSize
) -> Pin<Box<dyn Future<Output = Result<Option<AsyncDataSourceReader>, Error>> + Send, Global>>

异步数据源切片

fn source_key(&self) -> Result<Option<SourceKey<A>>, Error>

获取数据源 KEY

用于区分不同的数据源

该方法的异步版本为 [Self::async_source_key]。

fn async_source_key(
    &self
) -> Pin<Box<dyn Future<Output = Result<Option<SourceKey<A>>, Error>> + Send, Global>>

异步获取数据源 KEY

用于区分不同的数据源

fn total_size(&self) -> Result<Option<u64>, Error>

获取数据源大小

该方法的异步版本为 [Self::async_total_size]。

fn async_total_size(
    &self
) -> Pin<Box<dyn Future<Output = Result<Option<u64>, Error>> + Send, Global>>

异步获取数据源大小

impl<'a, A, T> DataSource<A> for &'a mut T where
    A: Digest,
    T: 'a + DataSource<A> + ?Sized,
    &'a mut T: Debug,
    &'a mut T: Sync,
    &'a mut T: Send, 

fn slice(&self, size: PartSize) -> Result<Option<DataSourceReader>, Error>

数据源切片

该方法的异步版本为 [Self::async_slice]。

fn async_slice(
    &self,
    size: PartSize
) -> Pin<Box<dyn Future<Output = Result<Option<AsyncDataSourceReader>, Error>> + Send, Global>>

异步数据源切片

fn source_key(&self) -> Result<Option<SourceKey<A>>, Error>

获取数据源 KEY

用于区分不同的数据源

该方法的异步版本为 [Self::async_source_key]。

fn async_source_key(
    &self
) -> Pin<Box<dyn Future<Output = Result<Option<SourceKey<A>>, Error>> + Send, Global>>

异步获取数据源 KEY

用于区分不同的数据源

fn total_size(&self) -> Result<Option<u64>, Error>

获取数据源大小

该方法的异步版本为 [Self::async_total_size]。

fn async_total_size(
    &self
) -> Pin<Box<dyn Future<Output = Result<Option<u64>, Error>> + Send, Global>>

异步获取数据源大小

impl<A, T> DataSource<A> for Rc<T> where
    A: Digest,
    T: DataSource<A> + ?Sized,
    Rc<T>: Debug,
    Rc<T>: Sync,
    Rc<T>: Send, 

fn slice(&self, size: PartSize) -> Result<Option<DataSourceReader>, Error>

数据源切片

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

fn async_slice(
    &self,
    size: PartSize
) -> Pin<Box<dyn Future<Output = Result<Option<AsyncDataSourceReader>, Error>> + Send, Global>>

异步数据源切片

fn source_key(&self) -> Result<Option<SourceKey<A>>, Error>

获取数据源 KEY

用于区分不同的数据源

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

fn async_source_key(
    &self
) -> Pin<Box<dyn Future<Output = Result<Option<SourceKey<A>>, Error>> + Send, Global>>

异步获取数据源 KEY

用于区分不同的数据源

fn total_size(&self) -> Result<Option<u64>, Error>

获取数据源大小

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

fn async_total_size(
    &self
) -> Pin<Box<dyn Future<Output = Result<Option<u64>, Error>> + Send, Global>>

异步获取数据源大小

impl<A, T> DataSource<A> for Box<T, Global> where
    A: Digest,
    T: DataSource<A> + ?Sized,
    Box<T, Global>: Debug,
    Box<T, Global>: Sync,
    Box<T, Global>: Send, 

fn slice(&self, size: PartSize) -> Result<Option<DataSourceReader>, Error>

数据源切片

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

fn async_slice(
    &self,
    size: PartSize
) -> Pin<Box<dyn Future<Output = Result<Option<AsyncDataSourceReader>, Error>> + Send, Global>>

异步数据源切片

fn source_key(&self) -> Result<Option<SourceKey<A>>, Error>

获取数据源 KEY

用于区分不同的数据源

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

fn async_source_key(
    &self
) -> Pin<Box<dyn Future<Output = Result<Option<SourceKey<A>>, Error>> + Send, Global>>

异步获取数据源 KEY

用于区分不同的数据源

fn total_size(&self) -> Result<Option<u64>, Error>

获取数据源大小

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

fn async_total_size(
    &self
) -> Pin<Box<dyn Future<Output = Result<Option<u64>, Error>> + Send, Global>>

异步获取数据源大小

Implementors

impl<D> DataSource<D> for FileDataSource<D> where
    D: Digest + Send,