Trait qiniu_sdk::prelude::DataSource

pub trait DataSource<A>: DynClone + Debug + Sync + Sendwhere
    A: Digest,{
    fn slice(&self, size: PartSize) -> Result<Option<DataSourceReader>, Error>;
    fn reset(&self) -> Result<(), Error>;
    fn total_size(&self) -> Result<Option<u64>, Error>;

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

数据源接口

提供上传所用的数据源

该 Trait 的异步版本为 AsyncDataSource。

Required Methods

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

数据源切片

fn reset(&self) -> Result<(), Error>

重置数据源

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

获取数据源大小

Provided Methods

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

获取数据源 KEY

用于区分不同的数据源

Implementations on Foreign Types

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

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

fn reset(&self) -> Result<(), Error>

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

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

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

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

fn reset(&self) -> Result<(), Error>

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

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

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

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

fn reset(&self) -> Result<(), Error>

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

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

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

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

fn reset(&self) -> Result<(), Error>

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

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

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

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

fn reset(&self) -> Result<(), Error>

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

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

Implementors

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

impl<R, A> DataSource<A> for UnseekableDataSource<R, A>where
    R: 'static + Read + Debug + Send + Sync,
    A: Digest,