Struct Client 

pub struct Client { /* private fields */ }

Implementations

impl Client

pub fn builder() -> ClientBuilder

Trait Implementations

impl AbortBucketWormOps for Client

async fn abort_bucket_worm(&self) -> Result<()>

Delete the bucket’s retention policy. Only possible before the policy is locked (i.e. while it is in the InProgress state and within the 24-hour window after creation).

impl AbortMultipartUploadOperations for Client

async fn abort_multipart_upload( &self, object_key: impl Into<String>, upload_id: impl Into<String>, ) -> Result<()>

Cancel multipart upload

impl AppendObjectOperations for Client

async fn append_object<T>( &self, object_key: impl Into<String>, position: u64, body: T, options: Option<AppendObjectOptions>, ) -> Result<AppendObjectResponse>

where T: Send + 'static, Bytes: From<T>,

Append data to an Appendable object.

async fn append_object_stream<S>( &self, object_key: impl Into<String>, position: u64, body: S, options: Option<AppendObjectOptions>, ) -> Result<AppendObjectResponse>

where S: TryStream + Send + 'static, S::Error: Into<BoxError>, Bytes: From<S::Ok>,

Append streaming data to an Appendable object.

impl CleanRestoredObjectOperations for Client

async fn clean_restored_object( &self, object_key: impl Into<String>, ) -> Result<()>

impl Clone for Client

fn clone(&self) -> Client

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl CloseMetaQueryOps for Client

async fn close_meta_query(&self) -> Result<()>

Disable the metadata-index library (asynchronously).

impl CompleteBucketWormOps for Client

async fn complete_bucket_worm(&self, worm_id: impl Into<String>) -> Result<()>

Lock a retention policy so the retention period can no longer be shortened or the policy deleted.

impl CompleteMultipartUploadOperations for Client

async fn complete_multipart_upload( &self, object_key: impl Into<String>, upload_id: impl Into<String>, parts: Vec<Part>, options: Option<CompleteMultipartUploadOptions>, ) -> Result<CompleteMultipartUploadResult>

Complete multipart upload

async fn complete_multipart_upload_auto( &self, object_key: impl Into<String>, upload_id: impl Into<String>, options: Option<CompleteMultipartUploadOptions>, ) -> Result<CompleteMultipartUploadResult>

Automatically complete multipart upload (server lists and sorts all parts)

impl CopyObjectOperations for Client

async fn copy_object( &self, source_bucket: impl Into<String>, source_key: impl Into<String>, target_key: impl Into<String>, options: Option<CopyObjectOptions>, ) -> Result<CopyObjectResult>

Copy an object within a bucket or between buckets in the same region

async fn copy_object_with_version_id( &self, source_bucket: impl Into<String>, source_key: impl Into<String>, source_version_id: impl Into<String>, target_key: impl Into<String>, options: Option<CopyObjectOptions>, ) -> Result<CopyObjectResult>

Copy an object within a bucket or between buckets in the same region

impl CreateAccessPointForObjectProcessOps for Client

async fn create_access_point_for_object_process( &self, fc_ap_name: impl Into<String>, config: CreateAccessPointForObjectProcessConfiguration, ) -> Result<CreateAccessPointForObjectProcessResult>

Create an Object FC access point backed by a Function Compute function.

impl CreateAccessPointOps for Client

async fn create_access_point( &self, config: CreateAccessPointConfiguration, ) -> Result<CreateAccessPointResult>

Create an access point for the bucket.

impl CreateBucketDataRedundancyTransitionOps for Client

async fn create_bucket_data_redundancy_transition( &self, target: DataRedundancyType, ) -> Result<CreateBucketDataRedundancyTransitionResponse>

Start a redundancy type conversion task on the bucket.

impl CreateCnameTokenOps for Client

async fn create_cname_token( &self, domain: impl Into<String>, ) -> Result<CnameToken>

Create a CNAME token used to verify ownership of a custom domain.

impl CreateDirectoryOperations for Client

async fn create_directory(&self, object_key: impl Into<String>) -> Result<()>

Create a directory (HNS-enabled buckets only).

impl CreateSelectObjectMetaOps for Client

async fn create_select_csv_object_meta( &self, key: impl Into<String>, request: CsvMetaRequest, ) -> Result<SelectFrameStream<Response>>

Build a meta-index for a CSV object.

async fn create_select_json_object_meta( &self, key: impl Into<String>, request: JsonMetaRequest, ) -> Result<SelectFrameStream<Response>>

Build a meta-index for a JSON-Lines object.

impl DataIndexingOperations for Client

async fn do_meta_query( &self, mode: DoMetaQueryMode, body: MetaQueryBody, query: DoMetaQueryParams, ) -> Result<MetaQueryResponse>

Query files (objects) that meet the specified conditions

impl Debug for Client

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

Formats the value using the given formatter.

impl DeleteAccessPointForObjectProcessOps for Client

async fn delete_access_point_for_object_process( &self, fc_ap_name: impl Into<String>, ) -> Result<()>

Delete an Object FC access point.

impl DeleteAccessPointOps for Client

async fn delete_access_point(&self, name: impl Into<String>) -> Result<()>

Delete an access point by name.

impl DeleteAccessPointPolicyForObjectProcessOps for Client

async fn delete_access_point_policy_for_object_process( &self, fc_ap_name: impl Into<String>, ) -> Result<()>

Delete the policy attached to an Object FC access point.

impl DeleteAccessPointPolicyOps for Client

async fn delete_access_point_policy( &self, name: impl Into<String>, ) -> Result<()>

Delete the policy associated with an access point.

impl DeleteAccessPointPublicAccessBlockOps for Client

async fn delete_access_point_public_access_block( &self, name: impl Into<String>, ) -> Result<()>

Delete the Block Public Access configuration of an access point.

impl DeleteBucketCorsOps for Client

async fn delete_bucket_cors(&self) -> Result<()>

Disable CORS and delete all CORS rules for the bucket.

impl DeleteBucketDataAcceleratorOps for Client

async fn delete_bucket_data_accelerator( &self, available_zone: impl Into<String>, ) -> Result<()>

Delete the OSS accelerator configuration for a specific zone.

impl DeleteBucketDataRedundancyTransitionOps for Client

async fn delete_bucket_data_redundancy_transition( &self, task_id: impl Into<String>, ) -> Result<()>

Delete a redundancy type conversion task. Tasks in Processing state cannot be deleted.

impl DeleteBucketEncryptionOps for Client

async fn delete_bucket_encryption(&self) -> Result<()>

Delete the bucket’s default server-side encryption rule.

impl DeleteBucketInventoryOps for Client

async fn delete_bucket_inventory( &self, inventory_id: impl Into<String>, ) -> Result<()>

Delete an inventory rule by ID.

impl DeleteBucketLifecycleOps for Client

async fn delete_bucket_lifecycle(&self) -> Result<()>

Delete all lifecycle rules for a bucket. Objects are not affected.

impl DeleteBucketLoggingOps for Client

async fn delete_bucket_logging(&self) -> Result<()>

Disable bucket access logging.

impl DeleteBucketOps for Client

async fn delete_bucket(&self) -> Result<()>

Delete a bucket

impl DeleteBucketPolicyOps for Client

async fn delete_bucket_policy(&self) -> Result<()>

Delete the bucket’s authorization policy.

impl DeleteBucketPublicAccessBlockOps for Client

async fn delete_bucket_public_access_block(&self) -> Result<()>

Delete the bucket-level Block Public Access configuration.

impl DeleteBucketQoSInfoOps for Client

async fn delete_bucket_qos_info(&self) -> Result<()>

Delete the bucket’s QoS configuration.

impl DeleteBucketReplicationOps for Client

async fn delete_bucket_replication( &self, rule_id: impl Into<String>, ) -> Result<()>

Stop and delete a replication rule.

impl DeleteBucketRequesterQoSInfoOps for Client

async fn delete_bucket_requester_qos_info( &self, qos_requester: impl Into<String>, ) -> Result<()>

Delete the bucket’s per-requester QoS for a given UID.

impl DeleteBucketTagsOps for Client

async fn delete_bucket_tags(&self, keys: Option<Vec<String>>) -> Result<()>

Delete the tags configured on the bucket.

impl DeleteBucketWebsiteOps for Client

async fn delete_bucket_website(&self) -> Result<()>

Disable static website hosting and clear routing rules.

impl DeleteCnameOps for Client

async fn delete_cname(&self, domain: impl Into<String>) -> Result<()>

Delete the CNAME record mapped to this bucket.

impl DeleteDirectoryOperations for Client

async fn delete_directory( &self, object_key: impl Into<String>, options: Option<DeleteDirectoryOptions>, ) -> Result<DeleteDirectoryResponse>

impl DeleteLiveChannelOperations for Client

async fn delete_live_channel( &self, channel_name: impl Into<String>, ) -> Result<()>

impl DeleteMultipleObjectsOperations for Client

async fn delete_multiple_objects( &self, configuration: DeleteMultipleObjectsConfiguration, encoding_type: Option<String>, ) -> Result<DeleteMultipleObjectsResponse>

Delete multiple objects in a single request.

impl DeleteObjectOperations for Client

async fn delete_object( &self, object_key: impl Into<String>, params: Option<DeleteObjectParams>, ) -> Result<()>

Delete an object

impl DeleteObjectTaggingOperations for Client

async fn delete_object_tagging( &self, object_key: impl Into<String>, params: Option<DeleteObjectTaggingParams>, ) -> Result<()>

impl DeletePublicAccessBlockOps for Client

async fn delete_public_access_block(&self) -> Result<()>

Delete the global Block Public Access configuration.

impl DeleteResourcePoolBucketGroupQoSInfoOps for Client

async fn delete_resource_pool_bucket_group_qos_info( &self, resource_pool: impl Into<String>, resource_pool_bucket_group: impl Into<String>, ) -> Result<()>

Delete QoS configuration for a bucket-group inside a resource pool.

impl DeleteResourcePoolRequesterQoSInfoOps for Client

async fn delete_resource_pool_requester_qos_info( &self, resource_pool: impl Into<String>, qos_requester: impl Into<String>, ) -> Result<()>

Delete per-requester QoS against a resource pool.

impl DeleteStyleOps for Client

async fn delete_style(&self, name: impl Into<String>) -> Result<()>

Delete a specific image style from this bucket.

impl DeleteUserDefinedLogFieldsConfigOps for Client

async fn delete_user_defined_log_fields_config(&self) -> Result<()>

Remove the custom logging-field configuration.

impl DeleteVectorBucketOps for Client

async fn delete_vector_bucket(&self) -> Result<()>

Delete the current vector bucket. Returns VectorBucketNotEmpty until all indexes are removed.

impl DeleteVectorIndexOps for Client

async fn delete_vector_index(&self, index_name: impl Into<String>) -> Result<()>

Delete a vector index. This also deletes every vector stored in the index and is irreversible.

impl DeleteVectorsOps for Client

async fn delete_vectors(&self, request: DeleteVectorsRequest) -> Result<()>

Batch-delete up to 500 vectors by key. Missing keys are silently skipped. The operation is not atomic — a 5xx response can leave partial deletions.

impl DescribeRegionsOps for Client

async fn describe_regions(&self) -> Result<RegionInfoList>

Query endpoints of all supported OSS regions.

async fn describe_region( &self, region: impl Into<String>, ) -> Result<RegionInfoList>

Query endpoints of a single OSS region.

impl ExtendBucketWormOps for Client

async fn extend_bucket_worm( &self, worm_id: impl Into<String>, retention_period_in_days: u32, ) -> Result<()>

Extend the retention period of a locked retention policy.

impl GetAccessPointConfigForObjectProcessOps for Client

async fn get_access_point_config_for_object_process( &self, fc_ap_name: impl Into<String>, ) -> Result<GetAccessPointConfigForObjectProcessResult>

Retrieve the current configuration of an Object FC access point.

impl GetAccessPointForObjectProcessOps for Client

async fn get_access_point_for_object_process( &self, fc_ap_name: impl Into<String>, ) -> Result<GetAccessPointForObjectProcessResult>

Retrieve basic information about an Object FC access point.

impl GetAccessPointOps for Client

async fn get_access_point( &self, name: impl Into<String>, ) -> Result<GetAccessPointResult>

Retrieve the full configuration of a named access point.

impl GetAccessPointPolicyForObjectProcessOps for Client

async fn get_access_point_policy_for_object_process( &self, fc_ap_name: impl Into<String>, ) -> Result<Bytes>

Retrieve the raw JSON policy document attached to an Object FC access point.

impl GetAccessPointPolicyOps for Client

async fn get_access_point_policy( &self, name: impl Into<String>, ) -> Result<Bytes>

Retrieve the raw JSON policy document attached to an access point.

impl GetAccessPointPublicAccessBlockOps for Client

async fn get_access_point_public_access_block( &self, name: impl Into<String>, ) -> Result<PublicAccessBlockConfiguration>

Retrieve the Block Public Access configuration of an access point.

impl GetBucketAccessMonitorOps for Client

async fn get_bucket_access_monitor(&self) -> Result<AccessMonitorConfiguration>

Query the bucket access-tracking status.

impl GetBucketAclOps for Client

async fn get_bucket_acl(&self) -> Result<AccessControlPolicy>

Query the ACL of the bucket.

impl GetBucketArchiveDirectReadOps for Client

async fn get_bucket_archive_direct_read( &self, ) -> Result<ArchiveDirectReadConfiguration>

Query whether real-time Archive access is enabled for the bucket.

impl GetBucketCorsOps for Client

async fn get_bucket_cors(&self) -> Result<CorsConfiguration>

Query the bucket CORS configuration.

impl GetBucketDataAcceleratorOps for Client

async fn get_bucket_data_accelerator( &self, available_zone: Option<String>, verbose: bool, ) -> Result<DataAccelerator>

Query the OSS accelerator configuration of a bucket.

impl GetBucketDataRedundancyTransitionOps for Client

async fn get_bucket_data_redundancy_transition( &self, task_id: impl Into<String>, ) -> Result<GetBucketDataRedundancyTransitionResponse>

Query the status of a single redundancy type conversion task.

impl GetBucketEncryptionOps for Client

async fn get_bucket_encryption(&self) -> Result<ServerSideEncryptionRule>

Query the bucket’s default server-side encryption rule.

impl GetBucketHttpsConfigOps for Client

async fn get_bucket_https_config(&self) -> Result<HttpsConfiguration>

Query the bucket’s TLS and cipher-suite configuration.

impl GetBucketInfoOps for Client

async fn get_bucket_info(&self) -> Result<BucketDetail>

Get bucket information

impl GetBucketInventoryOps for Client

async fn get_bucket_inventory( &self, inventory_id: impl Into<String>, ) -> Result<InventoryConfiguration>

Retrieve a single inventory rule by ID.

impl GetBucketLifecycleOps for Client

async fn get_bucket_lifecycle(&self) -> Result<LifecycleConfiguration>

Query the lifecycle rules of a bucket.

impl GetBucketLocationOps for Client

async fn get_bucket_location(&self) -> Result<String>

Get bucket location

impl GetBucketLoggingOps for Client

async fn get_bucket_logging(&self) -> Result<BucketLoggingStatus>

Query the bucket access-logging configuration.

impl GetBucketPolicyOps for Client

async fn get_bucket_policy(&self) -> Result<Bytes>

Retrieve the raw JSON policy document configured on the bucket.

impl GetBucketPolicyStatusOps for Client

async fn get_bucket_policy_status(&self) -> Result<PolicyStatus>

Query whether the bucket’s policy allows public access.

impl GetBucketPublicAccessBlockOps for Client

async fn get_bucket_public_access_block( &self, ) -> Result<PublicAccessBlockConfiguration>

Retrieve the bucket-level Block Public Access configuration.

impl GetBucketQoSInfoOps for Client

async fn get_bucket_qos_info(&self) -> Result<QoSConfiguration>

Fetch the bucket’s QoS configuration.

impl GetBucketRefererOps for Client

async fn get_bucket_referer(&self) -> Result<RefererConfiguration>

Retrieve the Referer configuration.

impl GetBucketReplicationLocationOps for Client

async fn get_bucket_replication_location(&self) -> Result<ReplicationLocation>

List the regions to which the current bucket can replicate.

impl GetBucketReplicationOps for Client

async fn get_bucket_replication(&self) -> Result<ReplicationConfiguration>

Retrieve the replication rules configured on the bucket.

impl GetBucketReplicationProgressOps for Client

async fn get_bucket_replication_progress( &self, rule_id: impl Into<String>, ) -> Result<ReplicationProgress>

Query the replication progress for a specific rule.

impl GetBucketRequestPaymentOps for Client

async fn get_bucket_request_payment( &self, ) -> Result<RequestPaymentConfiguration>

Query the pay-by-requester configuration of the bucket.

impl GetBucketRequesterQoSInfoOps for Client

async fn get_bucket_requester_qos_info( &self, qos_requester: impl Into<String>, ) -> Result<RequesterQoSInfo>

Fetch the bucket’s per-requester QoS for a given UID.

impl GetBucketResourceGroupOps for Client

async fn get_bucket_resource_group( &self, ) -> Result<BucketResourceGroupConfiguration>

Query the resource group of the bucket.

impl GetBucketStatOps for Client

async fn get_bucket_stat(&self) -> Result<BucketStat>

Get bucket statistics data

impl GetBucketTagsOps for Client

async fn get_bucket_tags(&self) -> Result<Tagging>

Query the tags configured on the bucket.

impl GetBucketTransferAccelerationOps for Client

async fn get_bucket_transfer_acceleration( &self, ) -> Result<TransferAccelerationConfiguration>

Query the transfer acceleration state of the bucket.

impl GetBucketVersioningOps for Client

async fn get_bucket_versioning(&self) -> Result<VersioningConfiguration>

Query the versioning state of the bucket.

impl GetBucketWebsiteOps for Client

async fn get_bucket_website(&self) -> Result<WebsiteConfiguration>

Retrieve the static-website-hosting configuration.

impl GetBucketWormOps for Client

async fn get_bucket_worm(&self) -> Result<WormConfiguration>

Query the retention (WORM) policy configured on the bucket.

impl GetCnameTokenOps for Client

async fn get_cname_token(&self, domain: impl Into<String>) -> Result<CnameToken>

Retrieve the CNAME token for a custom domain.

impl GetLiveChannelHistoryOperations for Client

async fn get_live_channel_history( &self, channel_name: impl Into<String>, ) -> Result<GetLiveChannelHistoryResponse>

impl GetLiveChannelInfoOperations for Client

async fn get_live_channel_info( &self, channel_name: impl Into<String>, ) -> Result<LiveChannelConfiguration>

impl GetLiveChannelStatOperations for Client

async fn get_live_channel_stat( &self, channel_name: impl Into<String>, ) -> Result<GetLiveChannelStatResponse>

impl GetMetaQueryStatusOps for Client

async fn get_meta_query_status(&self) -> Result<MetaQueryStatus>

Query the status of the metadata-index library.

impl GetObjectAclOperations for Client

async fn get_object_acl( &self, object_key: impl Into<String>, params: Option<GetObjectAclParams>, ) -> Result<GetObjectAclResponse>

impl GetObjectMetaOperations for Client

async fn get_object_meta( &self, object_key: impl Into<String>, params: Option<GetObjectMetaParams>, ) -> Result<GetObjectMetaResponse>

impl GetObjectOperations for Client

async fn get_object( &self, object_key: impl Into<String>, params: GetObjectParams, options: Option<GetObjectOptions>, ) -> Result<Bytes>

Get an object (file)

async fn presign_get_object( &self, object_key: impl Into<String>, public: bool, params: GetObjectParams, options: Option<GetObjectOptions>, query_auth_options: QueryAuthOptions, ) -> Result<String>

impl GetObjectTaggingOperations for Client

async fn get_object_tagging( &self, object_key: impl Into<String>, params: Option<GetObjectTaggingParams>, ) -> Result<Tagging>

impl GetPublicAccessBlockOps for Client

async fn get_public_access_block( &self, ) -> Result<PublicAccessBlockConfiguration>

Retrieve the global Block Public Access configuration.

impl GetResourcePoolBucketGroupQoSInfoOps for Client

async fn get_resource_pool_bucket_group_qos_info( &self, resource_pool: impl Into<String>, resource_pool_bucket_group: impl Into<String>, ) -> Result<ResourcePoolBucketGroupQoSInfo>

Fetch QoS for a bucket-group inside a resource pool.

impl GetResourcePoolInfoOps for Client

async fn get_resource_pool_info( &self, resource_pool: impl Into<String>, ) -> Result<GetResourcePoolInfoResult>

Fetch info and QoS configuration for a resource pool.

impl GetResourcePoolRequesterQoSInfoOps for Client

async fn get_resource_pool_requester_qos_info( &self, resource_pool: impl Into<String>, qos_requester: impl Into<String>, ) -> Result<RequesterQoSInfo>

Fetch per-requester QoS against a resource pool.

impl GetStyleOps for Client

async fn get_style(&self, name: impl Into<String>) -> Result<StyleInfo>

Retrieve one image style by name.

impl GetSymlinkOperations for Client

async fn get_symlink( &self, object_key: impl Into<String>, params: GetSymlinkParams, ) -> Result<GetSymlinkResponse>

Get a symbolic link information

impl GetUserAntiDDosInfoOps for Client

async fn get_user_anti_ddos_info(&self) -> Result<AntiDdosListConfiguration>

List all account-level Anti-DDoS instances.

impl GetUserDefinedLogFieldsConfigOps for Client

async fn get_user_defined_log_fields_config( &self, ) -> Result<UserDefinedLogFieldsConfiguration>

Retrieve the custom logging-field configuration.

impl GetVectorBucketOps for Client

async fn get_vector_bucket(&self) -> Result<GetVectorBucketResult>

Fetch metadata of the current vector bucket.

impl GetVectorIndexOps for Client

async fn get_vector_index( &self, index_name: impl Into<String>, ) -> Result<GetVectorIndexResult>

Fetch metadata of a vector index.

impl GetVectorsOps for Client

async fn get_vectors( &self, request: GetVectorsRequest, ) -> Result<GetVectorsResult>

Batch-read vectors by key (1–100 keys per call).

impl GetVodPlaylistOperations for Client

async fn get_vod_playlist( &self, channel_name: impl Into<String>, start_time: u64, end_time: u64, ) -> Result<Bytes>

impl HeadObjectOperations for Client

async fn head_object( &self, object_name: impl Into<String>, params: HeadObjectParams, options: Option<HeadObjectOptions>, ) -> Result<HeadObjectResponse>

Get metadata for an object (file)

impl InitBucketAntiDDosInfoOps for Client

async fn init_bucket_anti_ddos_info( &self, instance_id: impl Into<String>, kind: AntiDdosType, domains: Vec<String>, ) -> Result<()>

Initialise an Anti-DDoS instance for the bucket, optionally whitelisting custom domain names to be protected.

impl InitUserAntiDDosInfoOps for Client

async fn init_user_anti_ddos_info(&self) -> Result<InitUserAntiDDosInfoResponse>

Create an OSS Anti-DDoS instance for the current account.

impl InitiateBucketWormOps for Client

async fn initiate_bucket_worm( &self, retention_period_in_days: u32, ) -> Result<InitiateBucketWormResponse>

Create a retention policy on the bucket. Returns the new WormId.

impl InitiateMultipartUploadOperations for Client

async fn initiate_multipart_upload( &self, object_key: impl Into<String>, options: Option<InitiateMultipartUploadOptions>, ) -> Result<InitiateMultipartUploadResult>

Initialize multipart upload

impl ListAccessPointsForObjectProcessOps for Client

async fn list_access_points_for_object_process( &self, max_keys: Option<u32>, continuation_token: Option<String>, ) -> Result<ListAccessPointsForObjectProcessResult>

List Object FC access points.

impl ListAccessPointsOps for Client

async fn list_access_points( &self, max_keys: Option<u32>, continuation_token: Option<String>, ) -> Result<ListAccessPointsResult>

List bucket-level access points. Issue the request against a user-level host (no bucket) to receive user-level access points instead.

impl ListBucketAntiDDosInfoOps for Client

async fn list_bucket_anti_ddos_info( &self, marker: Option<String>, max_keys: Option<u32>, ) -> Result<AntiDdosListConfiguration>

List the Anti-DDoS instances that protect this bucket.

impl ListBucketDataRedundancyTransitionOps for Client

async fn list_bucket_data_redundancy_transition( &self, ) -> Result<ListBucketDataRedundancyTransitionResult>

List all redundancy-type-conversion tasks on the bucket.

impl ListBucketInventoryOps for Client

async fn list_bucket_inventory( &self, params: Option<ListBucketInventoryParams>, ) -> Result<ListInventoryConfigurationsResult>

List all inventory rules on the bucket (paginated, up to 100 per page).

impl ListBucketRequesterQoSInfosOps for Client

async fn list_bucket_requester_qos_infos( &self, params: Option<ListBucketRequesterQoSInfosParams>, ) -> Result<ListBucketRequesterQoSInfosResult>

List all per-requester QoS configurations for the current bucket.

impl ListBucketsOps for Client

async fn list_buckets( &self, params: Option<ListBucketsParams>, ) -> Result<ListAllMyBucketsResult>

Lists all buckets that belong to your Alibaba Cloud account. You can specify the prefix, marker, or max-keys parameter to list buckets that meet specific conditions.

impl ListCnameOps for Client

async fn list_cname(&self) -> Result<ListCnameResult>

List every CNAME record mapped to the bucket.

impl ListLiveChannelOperations for Client

async fn list_live_channel( &self, params: Option<ListLiveChannelParams>, ) -> Result<ListLiveChannelResponse>

impl ListMultipartUploadsOperations for Client

async fn list_multipart_uploads( &self, params: Option<ListMultipartUploadsParams>, ) -> Result<ListMultipartUploadsResult>

List multipart upload events

impl ListObjectVersionsOps for Client

async fn list_object_versions( &self, params: Option<ListObjectVersionsParams>, ) -> Result<ListObjectVersionsResult>

List all object versions in a bucket, including delete markers.

impl ListObjectsOps for Client

async fn list_objects( &self, params: Option<ListObjectsV2Params>, ) -> Result<ListObjectsResult>

List objects in a bucket (V2)

async fn presign_list_objects( &self, public: bool, params: Option<ListObjectsV2Params>, query_auth_options: QueryAuthOptions, ) -> Result<String>

Presign list objects operation

impl ListObjectsV1Ops for Client

async fn list_objects_v1( &self, params: Option<ListObjectsV1Params>, ) -> Result<ListObjectsV1Result>

List objects in a bucket using the legacy V1 (GetBucket) protocol.

async fn presign_list_objects_v1( &self, public: bool, params: Option<ListObjectsV1Params>, query_auth_options: QueryAuthOptions, ) -> Result<String>

Presign a list-objects V1 URL.

impl ListPartsOperations for Client

async fn list_parts( &self, object_key: impl Into<String>, upload_id: impl Into<String>, params: Option<ListPartsParams>, ) -> Result<ListPartsResult>

List uploaded parts

impl ListResourcePoolBucketGroupQoSInfosOps for Client

async fn list_resource_pool_bucket_group_qos_infos( &self, params: ListResourcePoolBucketGroupQoSInfosParams, ) -> Result<ListResourcePoolBucketGroupQoSInfosResult>

List QoS configurations for all bucket-groups in a resource pool.

impl ListResourcePoolBucketGroupsOps for Client

async fn list_resource_pool_bucket_groups( &self, params: ListResourcePoolBucketGroupsParams, ) -> Result<ListResourcePoolBucketGroupsResult>

List bucket-groups inside a resource pool.

impl ListResourcePoolBucketsOps for Client

async fn list_resource_pool_buckets( &self, params: ListResourcePoolBucketsParams, ) -> Result<ListResourcePoolBucketsResult>

List buckets inside the given resource pool.

impl ListResourcePoolRequesterQoSInfosOps for Client

async fn list_resource_pool_requester_qos_infos( &self, params: ListResourcePoolRequesterQoSInfosParams, ) -> Result<ListResourcePoolRequesterQoSInfosResult>

List all per-requester QoS entries for the resource pool.

impl ListResourcePoolsOps for Client

async fn list_resource_pools( &self, params: Option<ListResourcePoolsParams>, ) -> Result<ListResourcePoolsResult>

List all resource pools owned by the current account.

impl ListStyleOps for Client

async fn list_style(&self) -> Result<StyleList>

List every image style configured for the bucket.

impl ListUserDataRedundancyTransitionOps for Client

async fn list_user_data_redundancy_transition( &self, params: Option<ListUserDataRedundancyTransitionParams>, ) -> Result<ListUserDataRedundancyTransitionResult>

Lists all data redundancy transition tasks of the current account.

impl ListVectorBucketsOps for Client

async fn list_vector_buckets( &self, params: Option<ListVectorBucketsParams>, ) -> Result<ListVectorBucketsResult>

List vector buckets belonging to the current account/region.

impl ListVectorIndexesOps for Client

async fn list_vector_indexes( &self, request: Option<ListVectorIndexesRequest>, ) -> Result<ListVectorIndexesResult>

List all vector indexes in the current vector bucket.

impl ListVectorsOps for Client

async fn list_vectors( &self, request: ListVectorsRequest, ) -> Result<ListVectorsResult>

Paginate (optionally in parallel) through every vector in an index.

impl OpenMetaQueryOps for Client

async fn open_meta_query( &self, mode: MetaQueryMode, config: OpenMetaQueryConfig, ) -> Result<()>

Enable the metadata-index library on the bucket.

impl OptionsObjectOps for Client

async fn options_object( &self, request: OptionsObjectRequest, ) -> Result<OptionsObjectResponse>

Send a CORS preflight (OPTIONS) request for an object.

impl PostVodPlaylistOperations for Client

async fn post_vod_playlist( &self, channel_name: impl Into<String>, playlist_name: impl Into<String>, start_time: u64, end_time: u64, ) -> Result<()>

impl PutAccessPointConfigForObjectProcessOps for Client

async fn put_access_point_config_for_object_process( &self, fc_ap_name: impl Into<String>, config: PutAccessPointConfigForObjectProcessConfiguration, ) -> Result<()>

Change the configuration of an Object FC access point.

impl PutAccessPointPolicyForObjectProcessOps for Client

async fn put_access_point_policy_for_object_process( &self, fc_ap_name: impl Into<String>, policy: impl Into<Bytes>, ) -> Result<()>

Attach a JSON access policy to an Object FC access point.

impl PutAccessPointPolicyOps for Client

async fn put_access_point_policy( &self, name: impl Into<String>, policy: impl Into<Bytes>, ) -> Result<()>

Attach a JSON IAM-like policy document to an access point.

impl PutAccessPointPublicAccessBlockOps for Client

async fn put_access_point_public_access_block( &self, name: impl Into<String>, block_public_access: bool, ) -> Result<()>

Enable or disable Block Public Access for an access point.

impl PutBucketAccessMonitorOps for Client

async fn put_bucket_access_monitor( &self, status: AccessMonitorStatus, ) -> Result<()>

Enable or disable access tracking for the bucket.

impl PutBucketAclOps for Client

async fn put_bucket_acl(&self, acl: BucketAcl) -> Result<()>

Configure or modify the ACL of the bucket. Overwrites any previous ACL. The ACL is supplied via the x-oss-acl request header, not in the request body.

impl PutBucketArchiveDirectReadOps for Client

async fn put_bucket_archive_direct_read(&self, enabled: bool) -> Result<()>

Enable or disable real-time access of Archive objects.

impl PutBucketCorsOps for Client

async fn put_bucket_cors(&self, config: CorsConfiguration) -> Result<()>

Set the bucket’s CORS rules. Overwrites any existing rules.

impl PutBucketDataAcceleratorOps for Client

async fn put_bucket_data_accelerator( &self, config: DataAcceleratorConfiguration, ) -> Result<()>

Create or modify the OSS accelerator configuration for this bucket.

impl PutBucketEncryptionOps for Client

async fn put_bucket_encryption( &self, rule: ServerSideEncryptionRule, ) -> Result<()>

Configure the default server-side encryption rule for the bucket.

impl PutBucketHttpsConfigOps for Client

async fn put_bucket_https_config( &self, config: HttpsConfiguration, ) -> Result<()>

Configure the bucket’s TLS versions and cipher-suite policy.

impl PutBucketInventoryOps for Client

async fn put_bucket_inventory( &self, config: InventoryConfiguration, ) -> Result<()>

Configure an inventory rule for the bucket. The rule’s id is used as both the inventoryId query parameter and the <Id> body element, so it must be set in config.

impl PutBucketLifecycleOps for Client

async fn put_bucket_lifecycle( &self, config: LifecycleConfiguration, options: Option<PutBucketLifecycleOptions>, ) -> Result<()>

Configure (overwrite) the lifecycle rules of a bucket.

impl PutBucketLoggingOps for Client

async fn put_bucket_logging(&self, status: BucketLoggingStatus) -> Result<()>

Enable or update bucket access logging.

impl PutBucketOps for Client

async fn put_bucket( &self, config: PutBucketConfiguration, options: Option<PutBucketOptions>, ) -> Result<()>

Create a new bucket

impl PutBucketPolicyOps for Client

async fn put_bucket_policy(&self, policy: impl Into<Bytes>) -> Result<()>

Set the bucket authorization policy (JSON).

impl PutBucketPublicAccessBlockOps for Client

async fn put_bucket_public_access_block( &self, block_public_access: bool, ) -> Result<()>

Enable or disable Block Public Access on the bucket.

impl PutBucketQoSInfoOps for Client

async fn put_bucket_qos_info( &self, configuration: QoSConfiguration, ) -> Result<()>

Set the bucket’s total QoS configuration.

impl PutBucketRefererOps for Client

async fn put_bucket_referer(&self, config: RefererConfiguration) -> Result<()>

Configure the Referer whitelist / blacklist on the bucket.

impl PutBucketReplicationOps for Client

async fn put_bucket_replication( &self, config: ReplicationConfiguration, ) -> Result<()>

Create a data replication rule for the bucket.

impl PutBucketRequestPaymentOps for Client

async fn put_bucket_request_payment(&self, payer: Payer) -> Result<()>

Set who pays for request and traffic fees.

impl PutBucketRequesterQoSInfoOps for Client

async fn put_bucket_requester_qos_info( &self, qos_requester: impl Into<String>, configuration: QoSConfiguration, ) -> Result<()>

Set the per-requester QoS for the given UID on the current bucket.

impl PutBucketResourceGroupOps for Client

async fn put_bucket_resource_group( &self, resource_group_id: impl Into<String>, ) -> Result<()>

Move the bucket to a different resource group. Pass the empty string to move to the default resource group.

impl PutBucketResourcePoolBucketGroupOps for Client

async fn put_bucket_resource_pool_bucket_group( &self, resource_pool: impl Into<String>, resource_pool_bucket_group: impl Into<String>, ) -> Result<()>

Place the bucket into (or out of) a bucket-group inside a resource pool.

impl PutBucketRtcOps for Client

async fn put_bucket_rtc( &self, rule_id: impl Into<String>, status: RtcStatus, ) -> Result<()>

Enable or disable Replication Time Control for an existing CRR rule.

impl PutBucketTagsOps for Client

async fn put_bucket_tags(&self, tags: Vec<Tag>) -> Result<()>

Add or modify tags on a bucket. Existing tags with matching keys are overwritten.

impl PutBucketTransferAccelerationOps for Client

async fn put_bucket_transfer_acceleration(&self, enabled: bool) -> Result<()>

Enable / disable transfer acceleration for the bucket.

impl PutBucketVersioningOps for Client

async fn put_bucket_versioning(&self, status: VersioningStatus) -> Result<()>

Enable or suspend versioning on the bucket.

impl PutBucketWebsiteOps for Client

async fn put_bucket_website(&self, config: WebsiteConfiguration) -> Result<()>

Enable static website hosting on the bucket, optionally with redirect / mirroring-based back-to-origin rules.

impl PutCnameOps for Client

async fn put_cname( &self, domain: impl Into<String>, certificate: Option<CertificateConfiguration>, ) -> Result<()>

Map a custom domain name to the bucket, optionally binding a TLS certificate.

impl PutLiveChannelOperations for Client

async fn put_live_channel( &self, channel_name: impl Into<String>, configuration: LiveChannelConfiguration, ) -> Result<PutLiveChannelResponse>

impl PutLiveChannelStatusOperations for Client

async fn put_live_channel_status( &self, channel_name: impl Into<String>, status: LiveChannelStatus, ) -> Result<()>

impl PutObjectAclOperations for Client

async fn put_object_acl( &self, object_key: impl Into<String>, acl: ObjectAcl, params: Option<PutObjectAclParams>, ) -> Result<()>

Set the ACL of an object.

impl PutObjectOperations for Client

async fn put_object<T>( &self, object_key: impl Into<String>, body: T, options: Option<PutObjectOptions>, ) -> Result<PutObjectResponse>

where T: Send + 'static, Bytes: From<T>,

Upload an object to OSS

async fn put_object_stream<S>( &self, object_key: impl Into<String>, stream: S, options: Option<PutObjectOptions>, ) -> Result<PutObjectResponse>

where S: TryStream + Send + 'static, S::Error: Into<BoxError>, Bytes: From<S::Ok>,

Upload an object to OSS

impl PutObjectTaggingOperations for Client

async fn put_object_tagging( &self, object_key: impl Into<String>, tagging: Tagging, params: Option<PutObjectTaggingParams>, ) -> Result<()>

impl PutPublicAccessBlockOps for Client

async fn put_public_access_block(&self, block_public_access: bool) -> Result<()>

Globally enable/disable Block Public Access for OSS resources.

impl PutResourcePoolBucketGroupQoSInfoOps for Client

async fn put_resource_pool_bucket_group_qos_info( &self, resource_pool: impl Into<String>, resource_pool_bucket_group: impl Into<String>, configuration: QoSConfiguration, ) -> Result<()>

Set QoS configuration for a bucket-group inside a resource pool.

impl PutResourcePoolRequesterQoSInfoOps for Client

async fn put_resource_pool_requester_qos_info( &self, resource_pool: impl Into<String>, qos_requester: impl Into<String>, configuration: QoSConfiguration, ) -> Result<()>

Put per-requester QoS against a resource pool.

impl PutStyleOps for Client

async fn put_style( &self, name: impl Into<String>, content: impl Into<String>, ) -> Result<()>

Create an image style for this bucket.

impl PutSymlinkOperations for Client

async fn put_symlink( &self, symlink_key: impl Into<String>, target_object: impl Into<String>, options: Option<PutSymlinkOptions>, ) -> Result<PutSymlinkResponse>

Create a symbolic link that points to a destination object

impl PutUserDefinedLogFieldsConfigOps for Client

async fn put_user_defined_log_fields_config( &self, config: UserDefinedLogFieldsConfiguration, ) -> Result<()>

Configure custom headers / query parameters to include in the user_defined_log_fields real-time log field.

impl PutVectorBucketOps for Client

async fn put_vector_bucket(&self) -> Result<()>

Create a new vector bucket. The bucket name is taken from the Client configuration; each account is capped at 10 vector buckets per region by default.

impl PutVectorIndexOps for Client

async fn put_vector_index(&self, request: PutVectorIndexRequest) -> Result<()>

Create a vector index.

impl PutVectorsOps for Client

async fn put_vectors(&self, request: PutVectorsRequest) -> Result<()>

Batch-insert or overwrite up to 500 vectors in a single call.

impl QueryVectorsOps for Client

async fn query_vectors( &self, request: QueryVectorsRequest, ) -> Result<QueryVectorsResult>

Find the top-K nearest neighbors of query_vector in index_name, optionally filtered by metadata.

impl RenameOperations for Client

async fn rename( &self, destination_key: impl Into<String>, source: impl Into<String>, ) -> Result<()>

Rename a directory or object (HNS-enabled buckets only).

impl RestoreObjectOperations for Client

async fn restore_object( &self, object_key: impl Into<String>, params: Option<RestoreObjectParams>, body: Option<RestoreRequest>, ) -> Result<RestoreObjectResponse>

impl SealAppendObjectOperations for Client

async fn seal_append_object( &self, object_key: impl Into<String>, position: u64, ) -> Result<SealAppendObjectResponse>

Seal an Appendable Object, preventing further appends.

impl SelectObjectOps for Client

async fn select_object_csv( &self, key: impl Into<String>, request: SelectRequest, ) -> Result<SelectFrameStream<Response>>

Run a CSV Select query and return a SelectFrameStream over the decoded frames. The caller must inspect the final End / MetaEnd* frame and treat any non-2xx status as a failure (the outer HTTP response may be 206 even when the select itself ultimately errored).

async fn select_object_json( &self, key: impl Into<String>, request: SelectRequest, ) -> Result<SelectFrameStream<Response>>

Run a JSON Select query; see [select_object_csv] for details.

impl UpdateBucketAntiDDosInfoOps for Client

async fn update_bucket_anti_ddos_info( &self, instance_id: impl Into<String>, status: AntiDdosStatus, domains: Vec<String>, ) -> Result<()>

Update the Anti-DDoS status or protected domain list of a bucket.

impl UpdateUserAntiDDosInfoOps for Client

async fn update_user_anti_ddos_info( &self, instance_id: impl Into<String>, status: AntiDdosStatus, ) -> Result<()>

Update the status of an account-level Anti-DDoS instance.

impl UploadPartCopyOperations for Client

async fn upload_part_copy( &self, object_key: impl Into<String>, upload_id: impl Into<String>, part_number: u32, source_bucket: impl Into<String>, source_key: impl Into<String>, options: Option<UploadPartCopyOptions>, ) -> Result<UploadPartCopyResult>

Upload part copy

async fn upload_part_copy_with_version_id( &self, object_key: impl Into<String>, upload_id: impl Into<String>, part_number: u32, source_bucket: impl Into<String>, source_key: impl Into<String>, source_version_id: impl Into<String>, options: Option<UploadPartCopyOptions>, ) -> Result<UploadPartCopyResult>

Upload part copy

impl UploadPartOperations for Client

async fn upload_part<T>( &self, object_key: impl Into<String>, upload_id: impl Into<String>, part_number: u32, body: T, ) -> Result<UploadPartResult>

where T: Send + 'static, Bytes: From<T>,

Upload part

async fn upload_part_stream<S>( &self, object_key: impl Into<String>, upload_id: impl Into<String>, part_number: u32, stream: S, ) -> Result<UploadPartResult>

where S: TryStream + Send + 'static, S::Error: Into<BoxError>, Bytes: From<S::Ok>,

Upload part

impl BucketLiveChannelOperations for Client