Struct qiniu_upload_manager::UploadManager

pub struct UploadManager(_);

上传管理器

Implementations

impl UploadManager

pub fn builder(
    upload_token: impl Into<UploadTokenSigner>
) -> UploadManagerBuilder

创建上传管理构建器

Examples found in repository

src/upload_manager.rs (line 34)

    pub fn new(upload_token: impl Into<UploadTokenSigner>) -> Self {
        Self::builder(upload_token).build()
    }

pub fn new(upload_token: impl Into<UploadTokenSigner>) -> Self

创建上传管理器

pub fn upload_token(&self) -> &UploadTokenSigner

获取上传凭证签发器

Examples found in repository

src/multi_parts_uploader/mod.rs (line 303)

    fn access_key(&self) -> ApiResult<AccessKey> {
        self.upload_manager().upload_token().access_key()
    }

    fn bucket_name(&self) -> ApiResult<BucketName> {
        self.upload_manager().upload_token().bucket_name()
    }

    #[cfg(feature = "async")]
    fn async_access_key(&self) -> BoxFuture<ApiResult<AccessKey>> {
        Box::pin(async move { self.upload_manager().upload_token().async_access_key().await })
    }

    #[cfg(feature = "async")]
    fn async_bucket_name(&self) -> BoxFuture<ApiResult<BucketName>> {
        Box::pin(async move { self.upload_manager().upload_token().async_bucket_name().await })
    }

    fn get_bucket_regions(&self, params: &ObjectParams) -> ApiResult<GotRegions> {
        if let Some(region_provider) = params.region_provider() {
            region_provider.get_all(Default::default())
        } else {
            self.get_bucket_region()?.get_all(Default::default())
        }
    }

    #[cfg(feature = "async")]
    fn async_get_bucket_regions<'a>(&'a self, params: &'a ObjectParams) -> BoxFuture<'a, ApiResult<GotRegions>> {
        Box::pin(async move {
            if let Some(region_provider) = params.region_provider() {
                region_provider.async_get_all(Default::default()).await
            } else {
                self.async_get_bucket_region()
                    .await?
                    .async_get_all(Default::default())
                    .await
            }
        })
    }

    fn get_up_endpoints(&self, params: &ObjectParams) -> ApiResult<Endpoints> {
        let options = EndpointsGetOptions::builder().service_names(&[ServiceName::Up]).build();
        let up_endpoints = if let Some(region_provider) = params.region_provider() {
            RegionsProviderEndpoints::new(region_provider)
                .get_endpoints(options)?
                .into_owned()
        } else {
            RegionsProviderEndpoints::new(self.get_bucket_region()?)
                .get_endpoints(options)?
                .into_owned()
        };
        Ok(up_endpoints)
    }

    #[cfg(feature = "async")]
    fn async_get_up_endpoints<'a>(&'a self, params: &'a ObjectParams) -> BoxFuture<'a, ApiResult<Endpoints>> {
        Box::pin(async move {
            let options = EndpointsGetOptions::builder().service_names(&[ServiceName::Up]).build();
            let up_endpoints = if let Some(region_provider) = params.region_provider() {
                RegionsProviderEndpoints::new(region_provider)
                    .async_get_endpoints(options)
                    .await?
                    .into_owned()
            } else {
                RegionsProviderEndpoints::new(self.async_get_bucket_region().await?)
                    .async_get_endpoints(options)
                    .await?
                    .into_owned()
            };
            Ok(up_endpoints)
        })
    }

    fn get_bucket_region(&self) -> ApiResult<BucketRegionsProvider> {
        Ok(self
            .upload_manager()
            .queryer()
            .query(self.access_key()?, self.bucket_name()?))
    }

    #[cfg(feature = "async")]
    fn async_get_bucket_region(&self) -> BoxFuture<ApiResult<BucketRegionsProvider>> {
        Box::pin(async move {
            Ok(self
                .upload_manager()
                .queryer()
                .query(self.async_access_key().await?, self.async_bucket_name().await?))
        })
    }

    fn make_upload_token_signer(&self, object_name: Option<ObjectName>) -> OwnedUploadTokenProviderOrReferenced<'_> {
        self.upload_manager()
            .upload_token()
            .make_upload_token_provider(object_name)
    }

src/single_part_uploader/form_uploader.rs (line 387)

    fn make_upload_token_signer(&self, params: &ObjectParams) -> OwnedUploadTokenProviderOrReferenced<'_> {
        let object_name = params.object_name().map(ObjectName::from);
        self.upload_manager
            .upload_token()
            .make_upload_token_provider(object_name)
    }

    fn put_object(&self) -> put_object::Client {
        self.upload_manager.client().storage().put_object()
    }

    fn access_key(&self) -> ApiResult<AccessKey> {
        self.upload_manager.upload_token().access_key()
    }

    fn bucket_name(&self) -> ApiResult<BucketName> {
        self.upload_manager.upload_token().bucket_name()
    }

    #[cfg(feature = "async")]
    async fn async_access_key(&self) -> ApiResult<AccessKey> {
        self.upload_manager.upload_token().async_access_key().await
    }

    #[cfg(feature = "async")]
    async fn async_bucket_name(&self) -> ApiResult<BucketName> {
        self.upload_manager.upload_token().async_bucket_name().await
    }

pub fn client(&self) -> &QiniuApiClient

获取七牛 API 调用客户端

Examples found in repository

src/multi_parts_uploader/mod.rs (line 299)

    fn storage(&self) -> storage::Client {
        self.upload_manager().client().storage()
    }

src/single_part_uploader/form_uploader.rs (line 392)

    fn put_object(&self) -> put_object::Client {
        self.upload_manager.client().storage().put_object()
    }

pub fn queryer(&self) -> &BucketRegionsQueryer

获取存储空间相关区域查询器

Examples found in repository

src/single_part_uploader/form_uploader.rs (line 372)

    fn get_bucket_region(&self) -> ApiResult<BucketRegionsProvider> {
        Ok(self
            .upload_manager
            .queryer()
            .query(self.access_key()?, self.bucket_name()?))
    }

    #[cfg(feature = "async")]
    async fn async_get_bucket_region(&self) -> ApiResult<BucketRegionsProvider> {
        Ok(self
            .upload_manager
            .queryer()
            .query(self.async_access_key().await?, self.async_bucket_name().await?))
    }

src/multi_parts_uploader/mod.rs (line 378)

    fn get_bucket_region(&self) -> ApiResult<BucketRegionsProvider> {
        Ok(self
            .upload_manager()
            .queryer()
            .query(self.access_key()?, self.bucket_name()?))
    }

    #[cfg(feature = "async")]
    fn async_get_bucket_region(&self) -> BoxFuture<ApiResult<BucketRegionsProvider>> {
        Box::pin(async move {
            Ok(self
                .upload_manager()
                .queryer()
                .query(self.async_access_key().await?, self.async_bucket_name().await?))
        })
    }

pub fn single_part_uploader(&self) -> impl SinglePartUploader

创建默认的单请求上传器

pub fn form_uploader(&self) -> FormUploader

创建表单上传器

Examples found in repository

src/upload_manager.rs (line 58)

    pub fn single_part_uploader(&self) -> impl SinglePartUploader {
        self.form_uploader()
    }

pub fn multi_parts_uploader<H: Digest + Send + 'static, R: ResumableRecorder<HashAlgorithm = H> + 'static>(
    &self,
    resumable_recorder: R
) -> impl MultiPartsUploader<HashAlgorithm = H>

创建默认的分片上传器

pub fn multi_parts_v1_uploader<H: Digest + Send + 'static, R: ResumableRecorder<HashAlgorithm = H> + 'static>(
    &self,
    resumable_recorder: R
) -> MultiPartsV1Uploader<H>

创建分片上传器 V1

pub fn multi_parts_v2_uploader<H: Digest + Send + 'static, R: ResumableRecorder<HashAlgorithm = H> + 'static>(
    &self,
    resumable_recorder: R
) -> MultiPartsV2Uploader<H>

创建分片上传器 V2

Examples found in repository

src/upload_manager.rs (line 73)

    pub fn multi_parts_uploader<H: Digest + Send + 'static, R: ResumableRecorder<HashAlgorithm = H> + 'static>(
        &self,
        resumable_recorder: R,
    ) -> impl MultiPartsUploader<HashAlgorithm = H> {
        self.multi_parts_v2_uploader(resumable_recorder)
    }

pub fn auto_uploader<H: Digest + Send + 'static>(&self) -> AutoUploader<H>

创建自动上传器

pub fn auto_uploader_builder<H: Digest + Send + 'static>(
    &self
) -> AutoUploaderBuilder<H>

创建自动上传构建器

Trait Implementations

impl Clone for UploadManager

fn clone(&self) -> UploadManager

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for UploadManager

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.