Struct qiniu_objects_manager::Bucket

pub struct Bucket(_);

七牛存储空间管理器

Implementations

impl Bucket

pub fn name(&self) -> &BucketName

获取存储空间名称

pub fn objects_manager(&self) -> &ObjectsManager

获取对象管理器

pub fn list(&self) -> ListBuilder<'_>

创建列举操作构建器

阻塞代码示例

use qiniu_objects_manager::{apis::credential::Credential, ObjectsManager};
use futures::stream::TryStreamExt;

let credential = Credential::new("abcdefghklmnopq", "1234567890");
let object_manager = ObjectsManager::new(credential);
let bucket = object_manager.bucket("test-bucket");
let mut iter = bucket.list().iter();
while let Some(object) = iter.next() {
    let object = object?;
    println!("fsize: {:?}", object.get_size_as_u64());
    println!("hash: {:?}", object.get_hash_as_str());
    println!("mime_type: {:?}", object.get_mime_type_as_str());
}

异步代码示例

use qiniu_objects_manager::{apis::credential::Credential, ObjectsManager};
use futures::stream::TryStreamExt;

let credential = Credential::new("abcdefghklmnopq", "1234567890");
let object_manager = ObjectsManager::new(credential);
let bucket = object_manager.bucket("test-bucket");
let mut stream = bucket.list().stream();
while let Some(object) = stream.try_next().await? {
    println!("fsize: {:?}", object.get_size_as_u64());
    println!("hash: {:?}", object.get_hash_as_str());
    println!("mime_type: {:?}", object.get_mime_type_as_str());
}

pub fn stat_object<'a>(&'a self, object_name: &'a str) -> StatObjectBuilder<'a>

创建对象元信息获取操作构建器

阻塞代码示例

use qiniu_objects_manager::{apis::credential::Credential, ObjectsManager};

let credential = Credential::new("abcdefghklmnopq", "1234567890");
let object_manager = ObjectsManager::new(credential);
let bucket = object_manager.bucket("test-bucket");

let response = bucket.stat_object("test-key").call()?;
let object = response.into_body();
println!("fsize: {}", object.get_size_as_u64());
println!("hash: {}", object.get_hash_as_str());
println!("mime_type: {}", object.get_mime_type_as_str());

异步代码示例

use qiniu_objects_manager::{apis::credential::Credential, ObjectsManager};

let credential = Credential::new("abcdefghklmnopq", "1234567890");
let object_manager = ObjectsManager::new(credential);
let bucket = object_manager.bucket("test-bucket");

let response = bucket.stat_object("test-key").async_call().await?;
let object = response.into_body();
println!("fsize: {}", object.get_size_as_u64());
println!("hash: {}", object.get_hash_as_str());
println!("mime_type: {}", object.get_mime_type_as_str());

pub fn copy_object_to<'a>( &'a self, from_object_name: &'a str, to_bucket_name: &'a str, to_object_name: &'a str ) -> CopyObjectBuilder<'a>

创建对象复制操作构建器

阻塞代码示例

use qiniu_objects_manager::{apis::credential::Credential, ObjectsManager};

let credential = Credential::new("abcdefghklmnopq", "1234567890");
let object_manager = ObjectsManager::new(credential);
let bucket = object_manager.bucket("test-bucket");

bucket.copy_object_to("test-key", "test-bucket-2", "test-key").call()?;

异步代码示例

use qiniu_objects_manager::{apis::credential::Credential, ObjectsManager};

let credential = Credential::new("abcdefghklmnopq", "1234567890");
let object_manager = ObjectsManager::new(credential);
let bucket = object_manager.bucket("test-bucket");

bucket.copy_object_to("test-key", "test-bucket-2", "test-key").async_call().await?;

pub fn move_object_to<'a>( &'a self, from_object_name: &'a str, to_bucket_name: &'a str, to_object_name: &'a str ) -> MoveObjectBuilder<'a>

创建对象移动操作构建器

阻塞代码示例

use qiniu_objects_manager::{apis::credential::Credential, ObjectsManager};

let credential = Credential::new("abcdefghklmnopq", "1234567890");
let object_manager = ObjectsManager::new(credential);
let bucket = object_manager.bucket("test-bucket");

bucket.move_object_to("test-key", "test-bucket-2", "test-key").call()?;

异步代码示例

use qiniu_objects_manager::{apis::credential::Credential, ObjectsManager};

let credential = Credential::new("abcdefghklmnopq", "1234567890");
let object_manager = ObjectsManager::new(credential);
let bucket = object_manager.bucket("test-bucket");

bucket.move_object_to("test-key", "test-bucket-2", "test-key").async_call().await?;

pub fn delete_object<'a>( &'a self, object_name: &'a str ) -> DeleteObjectBuilder<'a>

创建对象删除操作构建器

阻塞代码示例

use qiniu_objects_manager::{apis::credential::Credential, ObjectsManager};

let credential = Credential::new("abcdefghklmnopq", "1234567890");
let object_manager = ObjectsManager::new(credential);
let bucket = object_manager.bucket("test-bucket");

bucket.delete_object("test-key").call()?;

异步代码示例

use qiniu_objects_manager::{apis::credential::Credential, ObjectsManager};

let credential = Credential::new("abcdefghklmnopq", "1234567890");
let object_manager = ObjectsManager::new(credential);
let bucket = object_manager.bucket("test-bucket");

bucket.delete_object("test-key").async_call().await?;

pub fn restore_archived_object<'a>( &'a self, object_name: &'a str, freeze_after_days: usize ) -> UnfreezeObjectBuilder<'a>

创建对象解冻操作构建器

阻塞代码示例

use qiniu_objects_manager::{apis::credential::Credential, ObjectsManager};

let credential = Credential::new("abcdefghklmnopq", "1234567890");
let object_manager = ObjectsManager::new(credential);
let bucket = object_manager.bucket("test-bucket");

bucket.restore_archived_object("test-key", 1).call()?;

异步代码示例

use qiniu_objects_manager::{apis::credential::Credential, ObjectsManager};

let credential = Credential::new("abcdefghklmnopq", "1234567890");
let object_manager = ObjectsManager::new(credential);
let bucket = object_manager.bucket("test-bucket");

bucket.restore_archived_object("test-key", 1).async_call().await?;

pub fn set_object_type<'a>( &'a self, object_name: &'a str, object_type: FileType ) -> SetObjectTypeBuilder<'a>

创建对象类型设置操作构建器

阻塞代码示例

use qiniu_objects_manager::{apis::{credential::Credential, upload_token::FileType}, ObjectsManager};

let credential = Credential::new("abcdefghklmnopq", "1234567890");
let object_manager = ObjectsManager::new(credential);
let bucket = object_manager.bucket("test-bucket");

bucket.set_object_type("test-key", FileType::Archive).call()?;

异步代码示例

use qiniu_objects_manager::{apis::{credential::Credential, upload_token::FileType}, ObjectsManager};

let credential = Credential::new("abcdefghklmnopq", "1234567890");
let object_manager = ObjectsManager::new(credential);
let bucket = object_manager.bucket("test-bucket");

bucket.set_object_type("test-key", FileType::Archive).async_call().await?;

pub fn modify_object_status<'a>( &'a self, object_name: &'a str, disable: bool ) -> ModifyObjectStatusBuilder<'a>

创建对象状态设置操作构建器

阻塞代码示例

use qiniu_objects_manager::{apis::credential::Credential, ObjectsManager};

let credential = Credential::new("abcdefghklmnopq", "1234567890");
let object_manager = ObjectsManager::new(credential);
let bucket = object_manager.bucket("test-bucket");

bucket.modify_object_status("test-key", true).call()?;

异步代码示例

use qiniu_objects_manager::{apis::credential::Credential, ObjectsManager};

let credential = Credential::new("abcdefghklmnopq", "1234567890");
let object_manager = ObjectsManager::new(credential);
let bucket = object_manager.bucket("test-bucket");

bucket.modify_object_status("test-key", true).async_call().await?;

pub fn modify_object_metadata<'a>( &'a self, object_name: &'a str, mime_type: Mime ) -> ModifyObjectMetadataBuilder<'a>

创建对象元信息设置操作构建器

use qiniu_objects_manager::{apis::credential::Credential, ObjectsManager, mime::APPLICATION_JSON};

let credential = Credential::new("abcdefghklmnopq", "1234567890");
let object_manager = ObjectsManager::new(credential);
let bucket = object_manager.bucket("test-bucket");

bucket.modify_object_metadata("test-key", APPLICATION_JSON).async_call().await?;

pub fn modify_object_life_cycle<'a>( &'a self, object_name: &'a str ) -> ModifyObjectLifeCycleBuilder<'a>

创建对象生命周期设置操作构建器

阻塞代码示例

use qiniu_objects_manager::{AfterDays, apis::credential::Credential, ObjectsManager};

let credential = Credential::new("abcdefghklmnopq", "1234567890");
let object_manager = ObjectsManager::new(credential);
let bucket = object_manager.bucket("test-bucket");

bucket.modify_object_life_cycle("test-key").delete_after_days(AfterDays::new(5)).call()?;

异步代码示例

use qiniu_objects_manager::{AfterDays, apis::credential::Credential, ObjectsManager};

let credential = Credential::new("abcdefghklmnopq", "1234567890");
let object_manager = ObjectsManager::new(credential);
let bucket = object_manager.bucket("test-bucket");

bucket.modify_object_life_cycle("test-key").delete_after_days(AfterDays::new(5)).async_call().await?;

pub fn batch_ops(&self) -> BatchOperations<'_>

创建批量操作

阻塞代码示例

use qiniu_objects_manager::{apis::credential::Credential, ObjectsManager, OperationProvider};

let credential = Credential::new("abcdefghklmnopq", "1234567890");
let object_manager = ObjectsManager::new(credential);
let bucket = object_manager.bucket("test-bucket");
let mut ops = bucket.batch_ops();
ops.add_operation(bucket.stat_object("test-file-1"));
ops.add_operation(bucket.stat_object("test-file-2"));
ops.add_operation(bucket.stat_object("test-file-3"));
ops.add_operation(bucket.stat_object("test-file-4"));
ops.add_operation(bucket.stat_object("test-file-5"));
let mut iter = ops.call();
while let Some(object) = iter.next() {
    let object = object?;
    println!("fsize: {:?}", object.get_size_as_u64());
    println!("hash: {:?}", object.get_hash_as_str());
    println!("mime_type: {:?}", object.get_mime_type_as_str());
}

异步代码示例

use qiniu_objects_manager::{apis::credential::Credential, ObjectsManager, OperationProvider};
use futures::stream::TryStreamExt;

let credential = Credential::new("abcdefghklmnopq", "1234567890");
let object_manager = ObjectsManager::new(credential);
let bucket = object_manager.bucket("test-bucket");
let mut ops = bucket.batch_ops();
ops.add_operation(bucket.stat_object("test-file-1"));
ops.add_operation(bucket.stat_object("test-file-2"));
ops.add_operation(bucket.stat_object("test-file-3"));
ops.add_operation(bucket.stat_object("test-file-4"));
ops.add_operation(bucket.stat_object("test-file-5"));
let mut stream = ops.async_call();
while let Some(object) = stream.try_next().await? {
    println!("fsize: {:?}", object.get_size_as_u64());
    println!("hash: {:?}", object.get_hash_as_str());
    println!("mime_type: {:?}", object.get_mime_type_as_str());
}

Trait Implementations

impl Clone for Bucket

fn clone(&self) -> Bucket

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Bucket

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

Formats the value using the given formatter.