Enum qiniu_http_client::Authorization

pub enum Authorization<'a> {
    Owned(Box<dyn AuthorizationProvider + 'a>),
    Borrowed(&'a dyn AuthorizationProvider),
}

七牛鉴权签名

该类型是个枚举类型，引用或拥有七牛鉴权签名接口的实例

Variants

Owned(Box<dyn AuthorizationProvider + 'a>)

拥有七牛鉴权签名接口的实例

Borrowed(&'a dyn AuthorizationProvider)

引用七牛鉴权签名接口的实例

Implementations

impl<'a> Authorization<'a>

pub fn from_owned<T: AuthorizationProvider + 'a>(provider: T) -> Self

根据一个拥有的七牛鉴权签名接口的实例创建一个鉴权签名

Examples found in repository

src/client/authorization.rs (line 424)

    pub fn uptoken(provider: impl UploadTokenProvider + Clone + 'a) -> Self {
        Self::from_owned(UploadTokenAuthorization::from(provider))
    }

    /// 根据认证信息获取接口创建一个使用七牛鉴权 v1 签名算法的签名
    #[inline]
    pub fn v1(provider: impl CredentialProvider + Clone + 'a) -> Self {
        Self::from_owned(CredentialAuthorizationV1::from(provider))
    }

    /// 根据认证信息获取接口创建一个使用七牛鉴权 v2 签名算法的签名
    #[inline]
    pub fn v2(provider: impl CredentialProvider + Clone + 'a) -> Self {
        Self::from_owned(CredentialAuthorizationV2::from(provider))
    }

    /// 根据认证信息获取接口创建一个使用七牛鉴权 v2 签名算法的签名，并且禁用时间戳签名
    #[inline]
    pub fn v2_without_timestamp_signature(provider: impl CredentialProvider + Clone + 'a) -> Self {
        let mut auth = CredentialAuthorizationV2::from(provider);
        auth.disable_timestamp_signature();
        Self::from_owned(auth)
    }

    /// 根据认证信息获取接口创建一个下载凭证签名算法的签名
    #[inline]
    pub fn download(provider: impl CredentialProvider + Clone + 'a) -> Self {
        Self::from_owned(DownloadUrlCredentialAuthorization::from(provider))
    }

pub fn from_referenced(provider: &'a dyn AuthorizationProvider) -> Self

根据一个引用的七牛鉴权签名接口的实例创建一个鉴权签名

pub fn uptoken(provider: impl UploadTokenProvider + Clone + 'a) -> Self

根据上传凭证获取接口创建一个上传凭证签名算法的签名

pub fn v1(provider: impl CredentialProvider + Clone + 'a) -> Self

根据认证信息获取接口创建一个使用七牛鉴权 v1 签名算法的签名

pub fn v2(provider: impl CredentialProvider + Clone + 'a) -> Self

根据认证信息获取接口创建一个使用七牛鉴权 v2 签名算法的签名

Examples found in repository

src/regions/regions_provider/all_regions_provider.rs (line 262)

        fn do_sync_query(&self) -> ApiResult<GotRegions> {
            handle_response_body(
                self.http_client
                    .get(&[ServiceName::Uc], &self.uc_endpoints)
                    .path("/regions")
                    .authorization(Authorization::v2(&self.credential_provider))
                    .accept_json()
                    .call()?
                    .parse_json::<ResponseBody>()?,
            )
        }

        #[cfg(feature = "async")]
        async fn do_async_query(&self) -> ApiResult<GotRegions> {
            handle_response_body(
                self.http_client
                    .async_get(&[ServiceName::Uc], &self.uc_endpoints)
                    .path("/regions")
                    .authorization(Authorization::v2(&self.credential_provider))
                    .accept_json()
                    .call()
                    .await?
                    .parse_json::<ResponseBody>()
                    .await?,
            )
        }

src/regions/endpoints_provider/bucket_domains_provider.rs (line 278)

    fn do_sync_query(&self) -> ApiResult<Endpoints> {
        let endpoints: Endpoints = self
            .queryer
            .http_client
            .get(&[ServiceName::Uc], &self.queryer.uc_endpoints)
            .path("/v2/domains")
            .authorization(Authorization::v2(&self.credential))
            .append_query_pair("tbl", self.bucket_name.as_str())
            .accept_json()
            .call()?
            .parse_json::<Vec<String>>()?
            .into_body()
            .into_iter()
            .map(Endpoint::from)
            .collect();
        Ok(endpoints)
    }

    #[cfg(feature = "async")]
    async fn do_async_query(&self) -> ApiResult<Endpoints> {
        let endpoints: Endpoints = self
            .queryer
            .http_client
            .async_get(&[ServiceName::Uc], &self.queryer.uc_endpoints)
            .path("/v2/domains")
            .authorization(Authorization::v2(&self.credential))
            .append_query_pair("tbl", self.bucket_name.as_str())
            .accept_json()
            .call()
            .await?
            .parse_json::<Vec<String>>()
            .await?
            .into_body()
            .into_iter()
            .map(Endpoint::from)
            .collect();
        Ok(endpoints)
    }

pub fn v2_without_timestamp_signature(
    provider: impl CredentialProvider + Clone + 'a
) -> Self

根据认证信息获取接口创建一个使用七牛鉴权 v2 签名算法的签名，并且禁用时间戳签名

pub fn download(provider: impl CredentialProvider + Clone + 'a) -> Self

根据认证信息获取接口创建一个下载凭证签名算法的签名

Trait Implementations

impl<'a> AsRef<dyn AuthorizationProvider + 'a> for Authorization<'a>

fn as_ref(&self) -> &(dyn AuthorizationProvider + 'a)

Converts this type into a shared reference of the (usually inferred) input type.

impl AuthorizationProvider for Authorization<'_>

fn sign(&self, request: &mut SyncRequest<'_>) -> AuthorizationResult<()>

使用指定的鉴权方式对 HTTP 请求进行签名

fn async_sign<'a>(
    &'a self,
    request: &'a mut AsyncRequest<'_>
) -> BoxFuture<'a, AuthorizationResult<()>>

Available on crate feature async only.

使用指定的鉴权方式对异步 HTTP 请求进行签名

impl<'a> Clone for Authorization<'a>

fn clone(&self) -> Authorization<'a>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<'a> Debug for Authorization<'a>

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

Formats the value using the given formatter.