various fixes for v0.8.0 #380
18 changed files with 47 additions and 47 deletions
|
@ -609,7 +609,7 @@ impl<S: Stream<Item = BlockStreamItem>> Defragmenter<S> {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Debug, Serialize, PartialEq)]
|
#[derive(Debug, Serialize, PartialEq, Eq)]
|
||||||
pub struct CopyObjectResult {
|
pub struct CopyObjectResult {
|
||||||
#[serde(rename = "LastModified")]
|
#[serde(rename = "LastModified")]
|
||||||
pub last_modified: s3_xml::Value,
|
pub last_modified: s3_xml::Value,
|
||||||
|
@ -617,7 +617,7 @@ pub struct CopyObjectResult {
|
||||||
pub etag: s3_xml::Value,
|
pub etag: s3_xml::Value,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Debug, Serialize, PartialEq)]
|
#[derive(Debug, Serialize, PartialEq, Eq)]
|
||||||
pub struct CopyPartResult {
|
pub struct CopyPartResult {
|
||||||
#[serde(serialize_with = "xmlns_tag")]
|
#[serde(serialize_with = "xmlns_tag")]
|
||||||
pub xmlns: (),
|
pub xmlns: (),
|
||||||
|
|
|
@ -25,7 +25,7 @@ impl From<&str> for Value {
|
||||||
#[derive(Debug, Serialize, Deserialize, PartialEq, Eq, PartialOrd, Ord)]
|
#[derive(Debug, Serialize, Deserialize, PartialEq, Eq, PartialOrd, Ord)]
|
||||||
pub struct IntValue(#[serde(rename = "$value")] pub i64);
|
pub struct IntValue(#[serde(rename = "$value")] pub i64);
|
||||||
|
|
||||||
#[derive(Debug, Serialize, PartialEq)]
|
#[derive(Debug, Serialize, PartialEq, Eq)]
|
||||||
pub struct Bucket {
|
pub struct Bucket {
|
||||||
#[serde(rename = "CreationDate")]
|
#[serde(rename = "CreationDate")]
|
||||||
pub creation_date: Value,
|
pub creation_date: Value,
|
||||||
|
@ -33,7 +33,7 @@ pub struct Bucket {
|
||||||
pub name: Value,
|
pub name: Value,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Debug, Serialize, PartialEq)]
|
#[derive(Debug, Serialize, PartialEq, Eq)]
|
||||||
pub struct Owner {
|
pub struct Owner {
|
||||||
#[serde(rename = "DisplayName")]
|
#[serde(rename = "DisplayName")]
|
||||||
pub display_name: Value,
|
pub display_name: Value,
|
||||||
|
@ -41,13 +41,13 @@ pub struct Owner {
|
||||||
pub id: Value,
|
pub id: Value,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Debug, Serialize, PartialEq)]
|
#[derive(Debug, Serialize, PartialEq, Eq)]
|
||||||
pub struct BucketList {
|
pub struct BucketList {
|
||||||
#[serde(rename = "Bucket")]
|
#[serde(rename = "Bucket")]
|
||||||
pub entries: Vec<Bucket>,
|
pub entries: Vec<Bucket>,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Debug, Serialize, PartialEq)]
|
#[derive(Debug, Serialize, PartialEq, Eq)]
|
||||||
pub struct ListAllMyBucketsResult {
|
pub struct ListAllMyBucketsResult {
|
||||||
#[serde(rename = "Buckets")]
|
#[serde(rename = "Buckets")]
|
||||||
pub buckets: BucketList,
|
pub buckets: BucketList,
|
||||||
|
@ -55,7 +55,7 @@ pub struct ListAllMyBucketsResult {
|
||||||
pub owner: Owner,
|
pub owner: Owner,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Debug, Serialize, PartialEq)]
|
#[derive(Debug, Serialize, PartialEq, Eq)]
|
||||||
pub struct LocationConstraint {
|
pub struct LocationConstraint {
|
||||||
#[serde(serialize_with = "xmlns_tag")]
|
#[serde(serialize_with = "xmlns_tag")]
|
||||||
pub xmlns: (),
|
pub xmlns: (),
|
||||||
|
@ -63,7 +63,7 @@ pub struct LocationConstraint {
|
||||||
pub region: String,
|
pub region: String,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Debug, Serialize, PartialEq)]
|
#[derive(Debug, Serialize, PartialEq, Eq)]
|
||||||
pub struct Deleted {
|
pub struct Deleted {
|
||||||
#[serde(rename = "Key")]
|
#[serde(rename = "Key")]
|
||||||
pub key: Value,
|
pub key: Value,
|
||||||
|
@ -73,7 +73,7 @@ pub struct Deleted {
|
||||||
pub delete_marker_version_id: Value,
|
pub delete_marker_version_id: Value,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Debug, Serialize, PartialEq)]
|
#[derive(Debug, Serialize, PartialEq, Eq)]
|
||||||
pub struct Error {
|
pub struct Error {
|
||||||
#[serde(rename = "Code")]
|
#[serde(rename = "Code")]
|
||||||
pub code: Value,
|
pub code: Value,
|
||||||
|
@ -85,7 +85,7 @@ pub struct Error {
|
||||||
pub region: Option<Value>,
|
pub region: Option<Value>,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Debug, Serialize, PartialEq)]
|
#[derive(Debug, Serialize, PartialEq, Eq)]
|
||||||
pub struct DeleteError {
|
pub struct DeleteError {
|
||||||
#[serde(rename = "Code")]
|
#[serde(rename = "Code")]
|
||||||
pub code: Value,
|
pub code: Value,
|
||||||
|
@ -97,7 +97,7 @@ pub struct DeleteError {
|
||||||
pub version_id: Option<Value>,
|
pub version_id: Option<Value>,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Debug, Serialize, PartialEq)]
|
#[derive(Debug, Serialize, PartialEq, Eq)]
|
||||||
pub struct DeleteResult {
|
pub struct DeleteResult {
|
||||||
#[serde(serialize_with = "xmlns_tag")]
|
#[serde(serialize_with = "xmlns_tag")]
|
||||||
pub xmlns: (),
|
pub xmlns: (),
|
||||||
|
@ -107,7 +107,7 @@ pub struct DeleteResult {
|
||||||
pub errors: Vec<DeleteError>,
|
pub errors: Vec<DeleteError>,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Debug, Serialize, PartialEq)]
|
#[derive(Debug, Serialize, PartialEq, Eq)]
|
||||||
pub struct InitiateMultipartUploadResult {
|
pub struct InitiateMultipartUploadResult {
|
||||||
#[serde(serialize_with = "xmlns_tag")]
|
#[serde(serialize_with = "xmlns_tag")]
|
||||||
pub xmlns: (),
|
pub xmlns: (),
|
||||||
|
@ -119,7 +119,7 @@ pub struct InitiateMultipartUploadResult {
|
||||||
pub upload_id: Value,
|
pub upload_id: Value,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Debug, Serialize, PartialEq)]
|
#[derive(Debug, Serialize, PartialEq, Eq)]
|
||||||
pub struct CompleteMultipartUploadResult {
|
pub struct CompleteMultipartUploadResult {
|
||||||
#[serde(serialize_with = "xmlns_tag")]
|
#[serde(serialize_with = "xmlns_tag")]
|
||||||
pub xmlns: (),
|
pub xmlns: (),
|
||||||
|
@ -133,7 +133,7 @@ pub struct CompleteMultipartUploadResult {
|
||||||
pub etag: Value,
|
pub etag: Value,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Debug, Serialize, PartialEq)]
|
#[derive(Debug, Serialize, PartialEq, Eq)]
|
||||||
pub struct Initiator {
|
pub struct Initiator {
|
||||||
#[serde(rename = "DisplayName")]
|
#[serde(rename = "DisplayName")]
|
||||||
pub display_name: Value,
|
pub display_name: Value,
|
||||||
|
@ -141,7 +141,7 @@ pub struct Initiator {
|
||||||
pub id: Value,
|
pub id: Value,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Debug, Serialize, PartialEq)]
|
#[derive(Debug, Serialize, PartialEq, Eq)]
|
||||||
pub struct ListMultipartItem {
|
pub struct ListMultipartItem {
|
||||||
#[serde(rename = "Initiated")]
|
#[serde(rename = "Initiated")]
|
||||||
pub initiated: Value,
|
pub initiated: Value,
|
||||||
|
@ -157,7 +157,7 @@ pub struct ListMultipartItem {
|
||||||
pub storage_class: Value,
|
pub storage_class: Value,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Debug, Serialize, PartialEq)]
|
#[derive(Debug, Serialize, PartialEq, Eq)]
|
||||||
pub struct ListMultipartUploadsResult {
|
pub struct ListMultipartUploadsResult {
|
||||||
#[serde(serialize_with = "xmlns_tag")]
|
#[serde(serialize_with = "xmlns_tag")]
|
||||||
pub xmlns: (),
|
pub xmlns: (),
|
||||||
|
@ -187,7 +187,7 @@ pub struct ListMultipartUploadsResult {
|
||||||
pub encoding_type: Option<Value>,
|
pub encoding_type: Option<Value>,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Debug, Serialize, PartialEq)]
|
#[derive(Debug, Serialize, PartialEq, Eq)]
|
||||||
pub struct PartItem {
|
pub struct PartItem {
|
||||||
#[serde(rename = "ETag")]
|
#[serde(rename = "ETag")]
|
||||||
pub etag: Value,
|
pub etag: Value,
|
||||||
|
@ -199,7 +199,7 @@ pub struct PartItem {
|
||||||
pub size: IntValue,
|
pub size: IntValue,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Debug, Serialize, PartialEq)]
|
#[derive(Debug, Serialize, PartialEq, Eq)]
|
||||||
pub struct ListPartsResult {
|
pub struct ListPartsResult {
|
||||||
#[serde(serialize_with = "xmlns_tag")]
|
#[serde(serialize_with = "xmlns_tag")]
|
||||||
pub xmlns: (),
|
pub xmlns: (),
|
||||||
|
@ -227,7 +227,7 @@ pub struct ListPartsResult {
|
||||||
pub storage_class: Value,
|
pub storage_class: Value,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Debug, Serialize, PartialEq)]
|
#[derive(Debug, Serialize, PartialEq, Eq)]
|
||||||
pub struct ListBucketItem {
|
pub struct ListBucketItem {
|
||||||
#[serde(rename = "Key")]
|
#[serde(rename = "Key")]
|
||||||
pub key: Value,
|
pub key: Value,
|
||||||
|
@ -241,13 +241,13 @@ pub struct ListBucketItem {
|
||||||
pub storage_class: Value,
|
pub storage_class: Value,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Debug, Serialize, PartialEq)]
|
#[derive(Debug, Serialize, PartialEq, Eq)]
|
||||||
pub struct CommonPrefix {
|
pub struct CommonPrefix {
|
||||||
#[serde(rename = "Prefix")]
|
#[serde(rename = "Prefix")]
|
||||||
pub prefix: Value,
|
pub prefix: Value,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Debug, Serialize, PartialEq)]
|
#[derive(Debug, Serialize, PartialEq, Eq)]
|
||||||
pub struct ListBucketResult {
|
pub struct ListBucketResult {
|
||||||
#[serde(serialize_with = "xmlns_tag")]
|
#[serde(serialize_with = "xmlns_tag")]
|
||||||
pub xmlns: (),
|
pub xmlns: (),
|
||||||
|
@ -281,7 +281,7 @@ pub struct ListBucketResult {
|
||||||
pub common_prefixes: Vec<CommonPrefix>,
|
pub common_prefixes: Vec<CommonPrefix>,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Debug, Serialize, PartialEq)]
|
#[derive(Debug, Serialize, PartialEq, Eq)]
|
||||||
pub struct VersioningConfiguration {
|
pub struct VersioningConfiguration {
|
||||||
#[serde(serialize_with = "xmlns_tag")]
|
#[serde(serialize_with = "xmlns_tag")]
|
||||||
pub xmlns: (),
|
pub xmlns: (),
|
||||||
|
@ -289,7 +289,7 @@ pub struct VersioningConfiguration {
|
||||||
pub status: Option<Value>,
|
pub status: Option<Value>,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Debug, Serialize, PartialEq)]
|
#[derive(Debug, Serialize, PartialEq, Eq)]
|
||||||
pub struct PostObject {
|
pub struct PostObject {
|
||||||
#[serde(serialize_with = "xmlns_tag")]
|
#[serde(serialize_with = "xmlns_tag")]
|
||||||
pub xmlns: (),
|
pub xmlns: (),
|
||||||
|
|
|
@ -7,7 +7,7 @@ use garage_table::*;
|
||||||
|
|
||||||
/// The bucket alias table holds the names given to buckets
|
/// The bucket alias table holds the names given to buckets
|
||||||
/// in the global namespace.
|
/// in the global namespace.
|
||||||
#[derive(PartialEq, Clone, Debug, Serialize, Deserialize)]
|
#[derive(PartialEq, Eq, Clone, Debug, Serialize, Deserialize)]
|
||||||
pub struct BucketAlias {
|
pub struct BucketAlias {
|
||||||
name: String,
|
name: String,
|
||||||
pub state: crdt::Lww<Option<Uuid>>,
|
pub state: crdt::Lww<Option<Uuid>>,
|
||||||
|
|
|
@ -12,7 +12,7 @@ use crate::permission::BucketKeyPerm;
|
||||||
/// Its parameters are not directly accessible as:
|
/// Its parameters are not directly accessible as:
|
||||||
/// - It must be possible to merge paramaters, hence the use of a LWW CRDT.
|
/// - It must be possible to merge paramaters, hence the use of a LWW CRDT.
|
||||||
/// - A bucket has 2 states, Present or Deleted and parameters make sense only if present.
|
/// - A bucket has 2 states, Present or Deleted and parameters make sense only if present.
|
||||||
#[derive(PartialEq, Clone, Debug, Serialize, Deserialize)]
|
#[derive(PartialEq, Eq, Clone, Debug, Serialize, Deserialize)]
|
||||||
pub struct Bucket {
|
pub struct Bucket {
|
||||||
/// ID of the bucket
|
/// ID of the bucket
|
||||||
pub id: Uuid,
|
pub id: Uuid,
|
||||||
|
@ -21,7 +21,7 @@ pub struct Bucket {
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Configuration for a bucket
|
/// Configuration for a bucket
|
||||||
#[derive(PartialEq, Clone, Debug, Serialize, Deserialize)]
|
#[derive(PartialEq, Eq, Clone, Debug, Serialize, Deserialize)]
|
||||||
pub struct BucketParams {
|
pub struct BucketParams {
|
||||||
/// Bucket's creation date
|
/// Bucket's creation date
|
||||||
pub creation_date: u64,
|
pub creation_date: u64,
|
||||||
|
|
|
@ -81,7 +81,7 @@ impl<T: CountedItem> CounterEntry<T> {
|
||||||
}
|
}
|
||||||
|
|
||||||
/// A counter entry in the global table
|
/// A counter entry in the global table
|
||||||
#[derive(PartialEq, Clone, Debug, Serialize, Deserialize)]
|
#[derive(PartialEq, Eq, Clone, Debug, Serialize, Deserialize)]
|
||||||
pub struct CounterValue {
|
pub struct CounterValue {
|
||||||
pub node_values: BTreeMap<Uuid, (u64, i64)>,
|
pub node_values: BTreeMap<Uuid, (u64, i64)>,
|
||||||
}
|
}
|
||||||
|
|
|
@ -9,7 +9,7 @@ use crate::permission::BucketKeyPerm;
|
||||||
use crate::prev::v051::key_table as old;
|
use crate::prev::v051::key_table as old;
|
||||||
|
|
||||||
/// An api key
|
/// An api key
|
||||||
#[derive(PartialEq, Clone, Debug, Serialize, Deserialize)]
|
#[derive(PartialEq, Eq, Clone, Debug, Serialize, Deserialize)]
|
||||||
pub struct Key {
|
pub struct Key {
|
||||||
/// The id of the key (immutable), used as partition key
|
/// The id of the key (immutable), used as partition key
|
||||||
pub key_id: String,
|
pub key_id: String,
|
||||||
|
@ -19,7 +19,7 @@ pub struct Key {
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Configuration for a key
|
/// Configuration for a key
|
||||||
#[derive(PartialEq, Clone, Debug, Serialize, Deserialize)]
|
#[derive(PartialEq, Eq, Clone, Debug, Serialize, Deserialize)]
|
||||||
pub struct KeyParams {
|
pub struct KeyParams {
|
||||||
/// The secret_key associated (immutable)
|
/// The secret_key associated (immutable)
|
||||||
pub secret_key: String,
|
pub secret_key: String,
|
||||||
|
|
|
@ -10,7 +10,7 @@ use super::key_table::PermissionSet;
|
||||||
/// Its parameters are not directly accessible as:
|
/// Its parameters are not directly accessible as:
|
||||||
/// - It must be possible to merge paramaters, hence the use of a LWW CRDT.
|
/// - It must be possible to merge paramaters, hence the use of a LWW CRDT.
|
||||||
/// - A bucket has 2 states, Present or Deleted and parameters make sense only if present.
|
/// - A bucket has 2 states, Present or Deleted and parameters make sense only if present.
|
||||||
#[derive(PartialEq, Clone, Debug, Serialize, Deserialize)]
|
#[derive(PartialEq, Eq, Clone, Debug, Serialize, Deserialize)]
|
||||||
pub struct Bucket {
|
pub struct Bucket {
|
||||||
/// Name of the bucket
|
/// Name of the bucket
|
||||||
pub name: String,
|
pub name: String,
|
||||||
|
@ -19,7 +19,7 @@ pub struct Bucket {
|
||||||
}
|
}
|
||||||
|
|
||||||
/// State of a bucket
|
/// State of a bucket
|
||||||
#[derive(PartialEq, Clone, Debug, Serialize, Deserialize)]
|
#[derive(PartialEq, Eq, Clone, Debug, Serialize, Deserialize)]
|
||||||
pub enum BucketState {
|
pub enum BucketState {
|
||||||
/// The bucket is deleted
|
/// The bucket is deleted
|
||||||
Deleted,
|
Deleted,
|
||||||
|
@ -41,7 +41,7 @@ impl Crdt for BucketState {
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Configuration for a bucket
|
/// Configuration for a bucket
|
||||||
#[derive(PartialEq, Clone, Debug, Serialize, Deserialize)]
|
#[derive(PartialEq, Eq, Clone, Debug, Serialize, Deserialize)]
|
||||||
pub struct BucketParams {
|
pub struct BucketParams {
|
||||||
/// Map of key with access to the bucket, and what kind of access they give
|
/// Map of key with access to the bucket, and what kind of access they give
|
||||||
pub authorized_keys: crdt::LwwMap<String, PermissionSet>,
|
pub authorized_keys: crdt::LwwMap<String, PermissionSet>,
|
||||||
|
|
|
@ -4,7 +4,7 @@ use garage_table::crdt::*;
|
||||||
use garage_table::*;
|
use garage_table::*;
|
||||||
|
|
||||||
/// An api key
|
/// An api key
|
||||||
#[derive(PartialEq, Clone, Debug, Serialize, Deserialize)]
|
#[derive(PartialEq, Eq, Clone, Debug, Serialize, Deserialize)]
|
||||||
pub struct Key {
|
pub struct Key {
|
||||||
/// The id of the key (immutable), used as partition key
|
/// The id of the key (immutable), used as partition key
|
||||||
pub key_id: String,
|
pub key_id: String,
|
||||||
|
|
|
@ -6,7 +6,7 @@ use garage_util::data::*;
|
||||||
use garage_table::crdt::*;
|
use garage_table::crdt::*;
|
||||||
|
|
||||||
/// An object
|
/// An object
|
||||||
#[derive(PartialEq, Clone, Debug, Serialize, Deserialize)]
|
#[derive(PartialEq, Eq, Clone, Debug, Serialize, Deserialize)]
|
||||||
pub struct Object {
|
pub struct Object {
|
||||||
/// The bucket in which the object is stored, used as partition key
|
/// The bucket in which the object is stored, used as partition key
|
||||||
pub bucket: String,
|
pub bucket: String,
|
||||||
|
@ -26,7 +26,7 @@ impl Object {
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Informations about a version of an object
|
/// Informations about a version of an object
|
||||||
#[derive(PartialEq, Clone, Debug, Serialize, Deserialize)]
|
#[derive(PartialEq, Eq, Clone, Debug, Serialize, Deserialize)]
|
||||||
pub struct ObjectVersion {
|
pub struct ObjectVersion {
|
||||||
/// Id of the version
|
/// Id of the version
|
||||||
pub uuid: Uuid,
|
pub uuid: Uuid,
|
||||||
|
@ -37,7 +37,7 @@ pub struct ObjectVersion {
|
||||||
}
|
}
|
||||||
|
|
||||||
/// State of an object version
|
/// State of an object version
|
||||||
#[derive(PartialEq, Clone, Debug, Serialize, Deserialize)]
|
#[derive(PartialEq, Eq, Clone, Debug, Serialize, Deserialize)]
|
||||||
pub enum ObjectVersionState {
|
pub enum ObjectVersionState {
|
||||||
/// The version is being received
|
/// The version is being received
|
||||||
Uploading(ObjectVersionHeaders),
|
Uploading(ObjectVersionHeaders),
|
||||||
|
|
|
@ -6,7 +6,7 @@ use garage_table::crdt::*;
|
||||||
use garage_table::*;
|
use garage_table::*;
|
||||||
|
|
||||||
/// A version of an object
|
/// A version of an object
|
||||||
#[derive(PartialEq, Clone, Debug, Serialize, Deserialize)]
|
#[derive(PartialEq, Eq, Clone, Debug, Serialize, Deserialize)]
|
||||||
pub struct Version {
|
pub struct Version {
|
||||||
/// UUID of the version, used as partition key
|
/// UUID of the version, used as partition key
|
||||||
pub uuid: Uuid,
|
pub uuid: Uuid,
|
||||||
|
|
|
@ -10,7 +10,7 @@ use garage_table::*;
|
||||||
|
|
||||||
use garage_block::manager::*;
|
use garage_block::manager::*;
|
||||||
|
|
||||||
#[derive(PartialEq, Clone, Debug, Serialize, Deserialize)]
|
#[derive(PartialEq, Eq, Clone, Debug, Serialize, Deserialize)]
|
||||||
pub struct BlockRef {
|
pub struct BlockRef {
|
||||||
/// Hash (blake2 sum) of the block, used as partition key
|
/// Hash (blake2 sum) of the block, used as partition key
|
||||||
pub block: Hash,
|
pub block: Hash,
|
||||||
|
|
|
@ -21,7 +21,7 @@ pub const UNFINISHED_UPLOADS: &str = "unfinished_uploads";
|
||||||
pub const BYTES: &str = "bytes";
|
pub const BYTES: &str = "bytes";
|
||||||
|
|
||||||
/// An object
|
/// An object
|
||||||
#[derive(PartialEq, Clone, Debug, Serialize, Deserialize)]
|
#[derive(PartialEq, Eq, Clone, Debug, Serialize, Deserialize)]
|
||||||
pub struct Object {
|
pub struct Object {
|
||||||
/// The bucket in which the object is stored, used as partition key
|
/// The bucket in which the object is stored, used as partition key
|
||||||
pub bucket_id: Uuid,
|
pub bucket_id: Uuid,
|
||||||
|
@ -70,7 +70,7 @@ impl Object {
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Informations about a version of an object
|
/// Informations about a version of an object
|
||||||
#[derive(PartialEq, Clone, Debug, Serialize, Deserialize)]
|
#[derive(PartialEq, Eq, Clone, Debug, Serialize, Deserialize)]
|
||||||
pub struct ObjectVersion {
|
pub struct ObjectVersion {
|
||||||
/// Id of the version
|
/// Id of the version
|
||||||
pub uuid: Uuid,
|
pub uuid: Uuid,
|
||||||
|
@ -81,7 +81,7 @@ pub struct ObjectVersion {
|
||||||
}
|
}
|
||||||
|
|
||||||
/// State of an object version
|
/// State of an object version
|
||||||
#[derive(PartialEq, Clone, Debug, Serialize, Deserialize)]
|
#[derive(PartialEq, Eq, Clone, Debug, Serialize, Deserialize)]
|
||||||
pub enum ObjectVersionState {
|
pub enum ObjectVersionState {
|
||||||
/// The version is being received
|
/// The version is being received
|
||||||
Uploading(ObjectVersionHeaders),
|
Uploading(ObjectVersionHeaders),
|
||||||
|
|
|
@ -15,7 +15,7 @@ use crate::s3::block_ref_table::*;
|
||||||
use crate::prev::v051::version_table as old;
|
use crate::prev::v051::version_table as old;
|
||||||
|
|
||||||
/// A version of an object
|
/// A version of an object
|
||||||
#[derive(PartialEq, Clone, Debug, Serialize, Deserialize)]
|
#[derive(PartialEq, Eq, Clone, Debug, Serialize, Deserialize)]
|
||||||
pub struct Version {
|
pub struct Version {
|
||||||
/// UUID of the version, used as partition key
|
/// UUID of the version, used as partition key
|
||||||
pub uuid: Uuid,
|
pub uuid: Uuid,
|
||||||
|
|
|
@ -3,7 +3,7 @@ use serde::{Deserialize, Serialize};
|
||||||
use crate::crdt::crdt::*;
|
use crate::crdt::crdt::*;
|
||||||
|
|
||||||
/// Boolean, where `true` is an absorbing state
|
/// Boolean, where `true` is an absorbing state
|
||||||
#[derive(Clone, Copy, Debug, Serialize, Deserialize, PartialEq)]
|
#[derive(Clone, Copy, Debug, Serialize, Deserialize, PartialEq, Eq)]
|
||||||
pub struct Bool(bool);
|
pub struct Bool(bool);
|
||||||
|
|
||||||
impl Bool {
|
impl Bool {
|
||||||
|
|
|
@ -3,7 +3,7 @@ use serde::{Deserialize, Serialize};
|
||||||
use crate::crdt::crdt::*;
|
use crate::crdt::crdt::*;
|
||||||
|
|
||||||
/// Deletable object (once deleted, cannot go back)
|
/// Deletable object (once deleted, cannot go back)
|
||||||
#[derive(Clone, Copy, Debug, Serialize, Deserialize, PartialEq)]
|
#[derive(Clone, Copy, Debug, Serialize, Deserialize, PartialEq, Eq)]
|
||||||
pub enum Deletable<T> {
|
pub enum Deletable<T> {
|
||||||
Present(T),
|
Present(T),
|
||||||
Deleted,
|
Deleted,
|
||||||
|
|
|
@ -37,7 +37,7 @@ use crate::crdt::crdt::*;
|
||||||
///
|
///
|
||||||
/// This scheme is used by AWS S3 or Soundcloud and often without knowing
|
/// This scheme is used by AWS S3 or Soundcloud and often without knowing
|
||||||
/// in enterprise when reconciliating databases with ad-hoc scripts.
|
/// in enterprise when reconciliating databases with ad-hoc scripts.
|
||||||
#[derive(Clone, Debug, Serialize, Deserialize, PartialEq)]
|
#[derive(Clone, Debug, Serialize, Deserialize, PartialEq, Eq)]
|
||||||
pub struct Lww<T> {
|
pub struct Lww<T> {
|
||||||
ts: u64,
|
ts: u64,
|
||||||
v: T,
|
v: T,
|
||||||
|
|
|
@ -23,7 +23,7 @@ use crate::crdt::crdt::*;
|
||||||
/// However, note that even if we were using a more efficient data structure such as a `BTreeMap`,
|
/// However, note that even if we were using a more efficient data structure such as a `BTreeMap`,
|
||||||
/// the serialization cost `O(n)` would still have to be paid at each modification, so we are
|
/// the serialization cost `O(n)` would still have to be paid at each modification, so we are
|
||||||
/// actually not losing anything here.
|
/// actually not losing anything here.
|
||||||
#[derive(Clone, Debug, Serialize, Deserialize, PartialEq)]
|
#[derive(Clone, Debug, Serialize, Deserialize, PartialEq, Eq)]
|
||||||
pub struct LwwMap<K, V> {
|
pub struct LwwMap<K, V> {
|
||||||
vals: Vec<(K, u64, V)>,
|
vals: Vec<(K, u64, V)>,
|
||||||
}
|
}
|
||||||
|
|
|
@ -16,7 +16,7 @@ use crate::crdt::crdt::*;
|
||||||
/// However, note that even if we were using a more efficient data structure such as a `BTreeMap`,
|
/// However, note that even if we were using a more efficient data structure such as a `BTreeMap`,
|
||||||
/// the serialization cost `O(n)` would still have to be paid at each modification, so we are
|
/// the serialization cost `O(n)` would still have to be paid at each modification, so we are
|
||||||
/// actually not losing anything here.
|
/// actually not losing anything here.
|
||||||
#[derive(Clone, Debug, Serialize, Deserialize, PartialEq)]
|
#[derive(Clone, Debug, Serialize, Deserialize, PartialEq, Eq)]
|
||||||
pub struct Map<K, V> {
|
pub struct Map<K, V> {
|
||||||
vals: Vec<(K, V)>,
|
vals: Vec<(K, V)>,
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue