pub struct Oss { /* private fields */ }Expand description
Aliyun Object Storage Service (OSS) support
§Capabilities
This service can be used to:
- stat
- read
- write
- append
- create_dir
- delete
- copy
- rename
- list
- presign
- blocking
§Configuration
root: Set the work dir for backend.bucket: Set the container name for backend.endpoint: Set the endpoint for backend.addressing_style: Set the addressing style for endpoint.presign_endpoint: Set the endpoint for presign.presign_addressing_style: Set the addressing style for presign endpoint.access_key_id: Set the access_key_id for backend.access_key_secret: Set the access_key_secret for backend.role_arn: Set the role of backend.oidc_token: Set the oidc_token for backend.allow_anonymous: Set the backend access OSS in anonymous way.
Refer to OssBuilder’s public API docs for more information.
§Example
§Via Builder
use std::sync::Arc;
use anyhow::Result;
use opendal::services::Oss;
use opendal::Operator;
#[tokio::main]
async fn main() -> Result<()> {
// Create OSS backend builder.
let mut builder = Oss::default()
// Set the root for oss, all operations will happen under this root.
//
// NOTE: the root must be absolute path.
.root("/path/to/dir")
// Set the bucket name, this is required.
.bucket("test")
// Set the endpoint.
//
// For example:
// - "https://oss-ap-northeast-1.aliyuncs.com"
// - "https://oss-hangzhou.aliyuncs.com"
.endpoint("https://oss-cn-beijing.aliyuncs.com")
// Set the access_key_id and access_key_secret.
//
// OpenDAL will try load credential from the env.
// If credential not set and no valid credential in env, OpenDAL will
// send request without signing like anonymous user.
.access_key_id("access_key_id")
.access_key_secret("access_key_secret");
let op: Operator = Operator::new(builder)?.finish();
Ok(())
}Implementations§
Source§impl OssBuilder
impl OssBuilder
Sourcepub fn root(self, root: &str) -> Self
Available on crate feature services-oss only.
pub fn root(self, root: &str) -> Self
services-oss only.Set root of this backend.
All operations will happen under this root.
Sourcepub fn bucket(self, bucket: &str) -> Self
Available on crate feature services-oss only.
pub fn bucket(self, bucket: &str) -> Self
services-oss only.Set bucket name of this backend.
Sourcepub fn endpoint(self, endpoint: &str) -> Self
Available on crate feature services-oss only.
pub fn endpoint(self, endpoint: &str) -> Self
services-oss only.Set endpoint of this backend.
Sourcepub fn addressing_style(self, addressing_style: &str) -> Self
Available on crate feature services-oss only.
pub fn addressing_style(self, addressing_style: &str) -> Self
services-oss only.Set addressing style for the endpoint.
Available values: virtual, cname, path.
-
virtual: Use virtual addressing style, i.e.http://bucket.oss-<region>.aliyuncs.com/object -
cname: Use cname addressing style, i.e.http://mydomain.com/objectwith mydomain.com bound to your bucket. -
path: Use path addressing style. i.e.http://oss-<region>.aliyuncs.com/bucket/object -
If not set, default value is
virtual.
Sourcepub fn enable_versioning(self, enabled: bool) -> Self
Available on crate feature services-oss only.
pub fn enable_versioning(self, enabled: bool) -> Self
services-oss only.Set bucket versioning status for this backend
Sourcepub fn presign_endpoint(self, endpoint: &str) -> Self
Available on crate feature services-oss only.
pub fn presign_endpoint(self, endpoint: &str) -> Self
services-oss only.Set an endpoint for generating presigned urls.
You can offer a public endpoint like https://oss-cn-beijing.aliyuncs.com to return a presinged url for public accessors, along with an internal endpoint like https://oss-cn-beijing-internal.aliyuncs.com to access objects in a faster path.
- If presign_endpoint is set, we will use presign_endpoint on generating presigned urls.
- if not, we will use endpoint as default.
Sourcepub fn presign_addressing_style(self, addressing_style: &str) -> Self
Available on crate feature services-oss only.
pub fn presign_addressing_style(self, addressing_style: &str) -> Self
services-oss only.Set addressing style for presign endpoint.
Similar to setting addressing style for endpoint.
-
If both presign_endpoint and presign_addressing_style are not set, they are the same as endpoint’s configurations.
-
If presign_endpoint is set, but presign_addressing_style is not set, default value is
virtual.
Sourcepub fn access_key_id(self, v: &str) -> Self
Available on crate feature services-oss only.
pub fn access_key_id(self, v: &str) -> Self
services-oss only.Set access_key_id of this backend.
- If access_key_id is set, we will take user’s input first.
- If not, we will try to load it from environment.
Sourcepub fn access_key_secret(self, v: &str) -> Self
Available on crate feature services-oss only.
pub fn access_key_secret(self, v: &str) -> Self
services-oss only.Set access_key_secret of this backend.
- If access_key_secret is set, we will take user’s input first.
- If not, we will try to load it from environment.
Sourcepub fn security_token(self, security_token: &str) -> Self
Available on crate feature services-oss only.
pub fn security_token(self, security_token: &str) -> Self
services-oss only.Set security_token for this backend.
- If security_token is set, we will take user’s input first.
- If not, we will try to load it from environment.
Sourcepub fn http_client(self, client: HttpClient) -> Self
👎Deprecated since 0.53.0: Use Operator::update_http_client insteadAvailable on crate feature services-oss only.
pub fn http_client(self, client: HttpClient) -> Self
Operator::update_http_client insteadservices-oss only.Specify the http client that used by this service.
§Notes
This API is part of OpenDAL’s Raw API. HttpClient could be changed
during minor updates.
Sourcepub fn server_side_encryption(self, v: &str) -> Self
Available on crate feature services-oss only.
pub fn server_side_encryption(self, v: &str) -> Self
services-oss only.Set server_side_encryption for this backend.
Available values: AES256, KMS.
Reference: https://www.alibabacloud.com/help/en/object-storage-service/latest/server-side-encryption-5
Brief explanation:
There are two server-side encryption methods available:
SSE-AES256:
1. Configure the bucket encryption mode as OSS-managed and specify the encryption algorithm as AES256.
2. Include the x-oss-server-side-encryption parameter in the request and set its value to AES256.
SSE-KMS:
1. To use this service, you need to first enable KMS.
2. Configure the bucket encryption mode as KMS, and specify the specific CMK ID for BYOK (Bring Your Own Key)
or not specify the specific CMK ID for OSS-managed KMS key.
3. Include the x-oss-server-side-encryption parameter in the request and set its value to KMS.
4. If a specific CMK ID is specified, include the x-oss-server-side-encryption-key-id parameter in the request, and set its value to the specified CMK ID.
Sourcepub fn server_side_encryption_key_id(self, v: &str) -> Self
Available on crate feature services-oss only.
pub fn server_side_encryption_key_id(self, v: &str) -> Self
services-oss only.Set server_side_encryption_key_id for this backend.
§Notes
This option only takes effect when server_side_encryption equals to KMS.
Sourcepub fn batch_max_operations(self, delete_max_size: usize) -> Self
👎Deprecated since 0.52.0: Please use delete_max_size instead of batch_max_operationsAvailable on crate feature services-oss only.
pub fn batch_max_operations(self, delete_max_size: usize) -> Self
delete_max_size instead of batch_max_operationsservices-oss only.Set maximum batch operations of this backend.
Sourcepub fn delete_max_size(self, delete_max_size: usize) -> Self
Available on crate feature services-oss only.
pub fn delete_max_size(self, delete_max_size: usize) -> Self
services-oss only.Set maximum delete operations of this backend.
Sourcepub fn allow_anonymous(self) -> Self
Available on crate feature services-oss only.
pub fn allow_anonymous(self) -> Self
services-oss only.Allow anonymous will allow opendal to send request without signing when credential is not loaded.
Sourcepub fn role_arn(self, role_arn: &str) -> Self
Available on crate feature services-oss only.
pub fn role_arn(self, role_arn: &str) -> Self
services-oss only.Set role_arn for this backend.
If role_arn is set, we will use already known config as source
credential to assume role with role_arn.
Sourcepub fn role_session_name(self, role_session_name: &str) -> Self
Available on crate feature services-oss only.
pub fn role_session_name(self, role_session_name: &str) -> Self
services-oss only.Set role_session_name for this backend.
Sourcepub fn oidc_provider_arn(self, oidc_provider_arn: &str) -> Self
Available on crate feature services-oss only.
pub fn oidc_provider_arn(self, oidc_provider_arn: &str) -> Self
services-oss only.Set oidc_provider_arn for this backend.
Sourcepub fn oidc_token_file(self, oidc_token_file: &str) -> Self
Available on crate feature services-oss only.
pub fn oidc_token_file(self, oidc_token_file: &str) -> Self
services-oss only.Set oidc_token_file for this backend.
Sourcepub fn sts_endpoint(self, sts_endpoint: &str) -> Self
Available on crate feature services-oss only.
pub fn sts_endpoint(self, sts_endpoint: &str) -> Self
services-oss only.Set sts_endpoint for this backend.
Trait Implementations§
Source§impl Builder for OssBuilder
Available on crate feature services-oss only.
impl Builder for OssBuilder
services-oss only.Source§impl Debug for OssBuilder
Available on crate feature services-oss only.
impl Debug for OssBuilder
services-oss only.Source§impl Default for OssBuilder
Available on crate feature services-oss only.
impl Default for OssBuilder
services-oss only.Source§fn default() -> OssBuilder
fn default() -> OssBuilder
Auto Trait Implementations§
impl Freeze for OssBuilder
impl !RefUnwindSafe for OssBuilder
impl Send for OssBuilder
impl Sync for OssBuilder
impl Unpin for OssBuilder
impl !UnwindSafe for OssBuilder
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
§impl<T> Conv for T
impl<T> Conv for T
§impl<T> FmtForward for T
impl<T> FmtForward for T
§fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
self to use its Binary implementation when Debug-formatted.§fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
self to use its Display implementation when
Debug-formatted.§fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
self to use its LowerExp implementation when
Debug-formatted.§fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
self to use its LowerHex implementation when
Debug-formatted.§fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
self to use its Octal implementation when Debug-formatted.§fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
self to use its Pointer implementation when
Debug-formatted.§fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
self to use its UpperExp implementation when
Debug-formatted.§fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
self to use its UpperHex implementation when
Debug-formatted.§fn fmt_list(self) -> FmtList<Self>where
&'a Self: for<'a> IntoIterator,
fn fmt_list(self) -> FmtList<Self>where
&'a Self: for<'a> IntoIterator,
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T in a tonic::RequestSource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T in a tonic::Request§impl<L> LayerExt<L> for L
impl<L> LayerExt<L> for L
§fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
Layered].§impl<T> Pipe for Twhere
T: ?Sized,
impl<T> Pipe for Twhere
T: ?Sized,
§fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
§fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
self and passes that borrow into the pipe function. Read more§fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
self and passes that borrow into the pipe function. Read more§fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
§fn pipe_borrow_mut<'a, B, R>(
&'a mut self,
func: impl FnOnce(&'a mut B) -> R,
) -> R
fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R, ) -> R
§fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
self, then passes self.as_ref() into the pipe function.§fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
self, then passes self.as_mut() into the pipe
function.§fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
self, then passes self.deref() into the pipe function.§impl<T> Pointable for T
impl<T> Pointable for T
§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
§impl<T> Tap for T
impl<T> Tap for T
§fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
Borrow<B> of a value. Read more§fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
BorrowMut<B> of a value. Read more§fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
AsRef<R> view of a value. Read more§fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
AsMut<R> view of a value. Read more§fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
Deref::Target of a value. Read more§fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
Deref::Target of a value. Read more§fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
.tap() only in debug builds, and is erased in release builds.§fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
.tap_mut() only in debug builds, and is erased in release
builds.§fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
.tap_borrow() only in debug builds, and is erased in release
builds.§fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
.tap_borrow_mut() only in debug builds, and is erased in release
builds.§fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
.tap_ref() only in debug builds, and is erased in release
builds.§fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
.tap_ref_mut() only in debug builds, and is erased in release
builds.§fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
.tap_deref() only in debug builds, and is erased in release
builds.