Struct Object

pub struct Object {

    pub kind: String,
    pub id: String,
    pub self_link: String,
    pub name: String,
    pub bucket: String,
    pub generation: i64,
    pub metageneration: i64,
    pub content_type: Option<String>,
    pub time_created: DateTime<Utc>,
    pub updated: DateTime<Utc>,
    pub time_deleted: Option<DateTime<Utc>>,
    pub temporary_hold: Option<bool>,
    pub event_based_hold: Option<bool>,
    pub retention_expiration_time: Option<DateTime<Utc>>,
    pub storage_class: String,
    pub time_storage_class_updated: DateTime<Utc>,
    pub size: u64,
    pub md5_hash: Option<String>,
    pub media_link: String,
    pub content_encoding: Option<String>,
    pub content_disposition: Option<String>,
    pub content_language: Option<String>,
    pub cache_control: Option<String>,
    pub metadata: Option<HashMap<String, String>>,
    pub acl: Option<Vec<ObjectAccessControl>>,
    pub owner: Option<Owner>,
    pub crc32c: String,
    pub component_count: Option<i32>,
    pub etag: String,
    pub customer_encryption: Option<CustomerEncrypton>,
    pub kms_key_name: Option<String>,
}

A resource representing a file in Google Cloud Storage.

Fields

kind: String

The kind of item this is. For objects, this is always storage#object.

id: String

The ID of the object, including the bucket name, object name, and generation number.

self_link: String

The link to this object.

name: String

The name of the object. Required if not specified by URL parameter.

bucket: String

The name of the bucket containing this object.

generation: i64

The content generation of this object. Used for object versioning.

metageneration: i64

The version of the metadata for this object at this generation. Used for preconditions and for detecting changes in metadata. A metageneration number is only meaningful in the context of a particular generation of a particular object.

content_type: Option<String>

Content-Type of the object data. If an object is stored without a Content-Type, it is served as application/octet-stream.

time_created: DateTime<Utc>

The creation time of the object in RFC 3339 format.

updated: DateTime<Utc>

The modification time of the object metadata in RFC 3339 format.

time_deleted: Option<DateTime<Utc>>

The deletion time of the object in RFC 3339 format. Returned if and only if this version of the object is no longer a live version, but remains in the bucket as a noncurrent version.

temporary_hold: Option<bool>

Whether or not the object is subject to a temporary hold.

event_based_hold: Option<bool>

Whether or not the object is subject to an event-based hold.

retention_expiration_time: Option<DateTime<Utc>>

The earliest time that the object can be deleted, based on a bucket’s retention policy, in RFC 3339 format.

storage_class: String

Storage class of the object.

time_storage_class_updated: DateTime<Utc>

The time at which the object’s storage class was last changed. When the object is initially created, it will be set to timeCreated.

size: u64

Content-Length of the data in bytes.

md5_hash: Option<String>

MD5 hash of the data; encoded using base64. For more information about using the MD5 hash, see Hashes and ETags: Best Practices.

media_link: String

Media download link.

content_encoding: Option<String>

Content-Encoding of the object data.

content_disposition: Option<String>

Content-Disposition of the object data.

content_language: Option<String>

Content-Language of the object data.

cache_control: Option<String>

Cache-Control directive for the object data. If omitted, and the object is accessible to all anonymous users, the default will be public, max-age=3600.

metadata: Option<HashMap<String, String>>

User-provided metadata, in key/value pairs.

acl: Option<Vec<ObjectAccessControl>>

Access controls on the object, containing one or more objectAccessControls Resources. If iamConfiguration.uniformBucketLevelAccess.enabled is set to true, this field is omitted in responses, and requests that specify this field fail.

owner: Option<Owner>

The owner of the object. This will always be the uploader of the object. If iamConfiguration.uniformBucketLevelAccess.enabled is set to true, this field does not apply, and is omitted in responses.

crc32c: String

CRC32c checksum, as described in RFC 4960, Appendix B; encoded using base64 in big-endian byte order. For more information about using the CRC32c checksum, see Hashes and ETags: Best Practices.

component_count: Option<i32>

Number of underlying components that make up a composite object. Components are accumulated by compose operations, counting 1 for each non-composite source object and componentCount for each composite source object. Note: componentCount is included in the metadata for composite objects only.

etag: String

HTTP 1.1 Entity tag for the object.

customer_encryption: Option<CustomerEncrypton>

Metadata of customer-supplied encryption key, if the object is encrypted by such a key.

kms_key_name: Option<String>

Cloud KMS Key used to encrypt this object, if the object is encrypted by such a key.

Implementations

impl Object

pub fn create( bucket: &str, file: &[u8], filename: &str, mime_type: &str, ) -> Result<Self, Error>

Create a new object. Upload a file as that is loaded in memory to google cloud storage, where it will be interpreted according to the mime type you specified.

Example

use cloud_storage::Object;

let file: Vec<u8> = read_cute_cat("cat.png");
Object::create("cat-photos", &file, "recently read cat.png", "image/png")
    .expect("cat not uploaded");

pub fn create_streamed<R: Read + Send + 'static>( bucket: &str, file: R, length: u64, filename: &str, mime_type: &str, ) -> Result<Self, Error>

Create a new object. This works in the same way as Object::create, except it does not need to load the entire file in ram.

Example

use cloud_storage::Object;

let mut file = std::io::Cursor::new(read_cute_cat("cat.png"));
Object::create_streamed("cat-photos", file, 10, "recently read cat.png", "image/png")
    .expect("cat not uploaded");
Ok(())

pub fn list(bucket: &str) -> Result<Vec<Self>, Error>

Obtain a list of objects within this Bucket.

Example

use cloud_storage::Object;

let all_objects = Object::list("my_bucket")?;

pub fn list_prefix(bucket: &str, prefix: &str) -> Result<Vec<Self>, Error>

Obtain a list of objects by prefix within this Bucket .

Example

use cloud_storage::Object;

let all_objects = Object::list_prefix("my_bucket", "prefix/")?;

pub fn read(bucket: &str, file_name: &str) -> Result<Self, Error>

Obtains a single object with the specified name in the specified bucket.

Example

use cloud_storage::Object;

let object = Object::read("my_bucket", "path/to/my/file.png")?;

pub fn download(bucket: &str, file_name: &str) -> Result<Vec<u8>, Error>

Download the content of the object with the specified name in the specified bucket.

Example

use cloud_storage::Object;

let bytes = Object::download("my_bucket", "path/to/my/file.png")?;

pub fn update(&self) -> Result<Self, Error>

Obtains a single object with the specified name in the specified bucket.

Example

use cloud_storage::Object;

let mut object = Object::read("my_bucket", "path/to/my/file.png")?;
object.content_type = Some("application/xml".to_string());
object.update();

pub fn delete(bucket: &str, file_name: &str) -> Result<(), Error>

Deletes a single object with the specified name in the specified bucket.

Example

use cloud_storage::Object;

Object::delete("my_bucket", "path/to/my/file.png")?;

pub fn compose( bucket: &str, req: &ComposeRequest, destination_object: &str, ) -> Result<Self, Error>

Obtains a single object with the specified name in the specified bucket.

Example

use cloud_storage::object::{Object, ComposeRequest, SourceObject};

let obj1 = Object::read("my_bucket", "file1")?;
let obj2 = Object::read("my_bucket", "file2")?;
let compose_request = ComposeRequest {
    kind: "storage#composeRequest".to_string(),
    source_objects: vec![
        SourceObject {
            name: obj1.name.clone(),
            generation: None,
            object_preconditions: None,
        },
        SourceObject {
            name: obj2.name.clone(),
            generation: None,
            object_preconditions: None,
        },
    ],
    destination: None,
};
let obj3 = Object::compose("my_bucket", &compose_request, "test-concatted-file")?;
// obj3 is now a file with the content of obj1 and obj2 concatted together.

pub fn copy(&self, destination_bucket: &str, path: &str) -> Result<Self, Error>

Copy this object to the target bucket and path

Example

use cloud_storage::object::{Object, ComposeRequest};

let obj1 = Object::read("my_bucket", "file1")?;
let obj2 = obj1.copy("my_other_bucket", "file2")?;
// obj2 is now a copy of obj1.

pub fn rewrite( &self, destination_bucket: &str, path: &str, ) -> Result<Self, Error>

Moves a file from the current location to the target bucket and path.

Limitations

This function does not yet support rewriting objects to another

• Geographical Location,
• Encryption,
• Storage class. These limitations mean that for now, the rewrite and the copy methods do the same thing.

Example

use cloud_storage::object::Object;

let obj1 = Object::read("my_bucket", "file1")?;
let obj2 = obj1.rewrite("my_other_bucket", "file2")?;
// obj2 is now a copy of obj1.

pub fn download_url(&self, duration: u32) -> Result<String, Error>

Creates a Signed Url which is valid for duration seconds, and lets the posessor download the file contents without any authentication.

Example

use cloud_storage::object::{Object, ComposeRequest};

let obj1 = Object::read("my_bucket", "file1")?;
let url = obj1.download_url(50)?;
// url is now a url to which an unauthenticated user can make a request to download a file
// for 50 seconds.

Trait Implementations

impl Debug for Object

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Object

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for Object

fn eq(&self, other: &Object) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for Object

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for Object