Struct garage_model::s3::mpu_table::MultipartUpload

pub struct MultipartUpload {
    pub upload_id: Uuid,
    pub timestamp: u64,
    pub deleted: Bool,
    pub parts: Map<MpuPartKey, MpuPart>,
    pub bucket_id: Uuid,
    pub key: String,
}

A part of a multipart upload

Fields

upload_id: Uuid

Partition key = Upload id = UUID of the object version

timestamp: u64

The timestamp at which the multipart upload was created

deleted: Bool

Is this multipart upload deleted The MultipartUpload is marked as deleted as soon as the multipart upload is either completed or aborted

parts: Map<MpuPartKey, MpuPart>

List of uploaded parts, key = (part number, timestamp) In case of retries, all versions for each part are kept Everything is cleaned up only once the MultipartUpload is marked deleted

bucket_id: Uuid

Bucket in which the related object is stored

key: String

Key in which the related object is stored

Implementations

impl MultipartUpload

pub fn new( upload_id: Uuid, timestamp: u64, bucket_id: Uuid, key: String, deleted: bool ) -> Self

pub fn next_timestamp(&self, part_number: u64) -> u64

Trait Implementations

impl Clone for MultipartUpload

fn clone(&self) -> MultipartUpload

Returns a copy of the value.

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

Performs copy-assignment from source.

impl CountedItem for MultipartUpload

const COUNTER_TABLE_NAME: &'static str = "bucket_mpu_counter"

type CP = FixedBytes32

type CS = EmptyKey

fn counter_partition_key(&self) -> &Uuid

fn counter_sort_key(&self) -> &EmptyKey

fn counts(&self) -> Vec<(&'static str, i64)>

impl Crdt for MultipartUpload

fn merge(&mut self, other: &Self)

Merge the two datastructures according to the CRDT rules. self is modified to contain the merged CRDT value. other is not modified.

impl Debug for MultipartUpload

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for MultipartUpload

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Entry<FixedBytes32, EmptyKey> for MultipartUpload

fn partition_key(&self) -> &Uuid

Get the key used to partition

fn sort_key(&self) -> &EmptyKey

Get the key used to sort

fn is_tombstone(&self) -> bool

Is the entry a tombstone? Default implementation always return false

impl InitialFormat for MultipartUpload

const VERSION_MARKER: &'static [u8] = b"G09s3mpu"

A sequence of bytes to add at the beginning of the serialized string, to identify that the data is of this version.

impl PartialEq for MultipartUpload

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

This method tests for self and other values to be equal, and is used by ==.

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

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

impl Serialize for MultipartUpload

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for MultipartUpload

impl StructuralPartialEq for MultipartUpload