garage/src/model/bucket_table.rs

120 lines
2.8 KiB
Rust
Raw Normal View History

use serde::{Deserialize, Serialize};
use garage_table::crdt::CRDT;
2020-04-24 10:10:01 +00:00
use garage_table::*;
use crate::key_table::PermissionSet;
2020-12-12 20:35:29 +00:00
/// A bucket is a collection of objects
///
/// Its parameters are not directly accessible as:
/// - 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.
#[derive(PartialEq, Clone, Debug, Serialize, Deserialize)]
pub struct Bucket {
2021-03-26 20:53:28 +00:00
/// Name of the bucket
pub name: String,
2021-03-26 20:53:28 +00:00
/// State, and configuration if not deleted, of the bucket
pub state: crdt::LWW<BucketState>,
}
2021-03-26 20:53:28 +00:00
/// State of a bucket
#[derive(PartialEq, Clone, Debug, Serialize, Deserialize)]
pub enum BucketState {
2021-03-26 20:53:28 +00:00
/// The bucket is deleted
Deleted,
2021-03-26 20:53:28 +00:00
/// The bucket exists
2020-12-12 16:00:31 +00:00
Present(BucketParams),
}
impl CRDT for BucketState {
fn merge(&mut self, o: &Self) {
match o {
BucketState::Deleted => *self = BucketState::Deleted,
2020-12-12 16:00:31 +00:00
BucketState::Present(other_params) => {
if let BucketState::Present(params) = self {
params.merge(other_params);
}
}
}
}
}
2021-03-26 20:53:28 +00:00
/// Configuration for a bucket
2020-12-12 16:00:31 +00:00
#[derive(PartialEq, Clone, Debug, Serialize, Deserialize)]
pub struct BucketParams {
2021-03-26 20:53:28 +00:00
/// Map of key with access to the bucket, and what kind of access they give
2020-12-12 16:00:31 +00:00
pub authorized_keys: crdt::LWWMap<String, PermissionSet>,
2021-03-26 20:53:28 +00:00
/// Is the bucket served as http
2020-12-15 11:48:24 +00:00
pub website: crdt::LWW<bool>,
2020-12-12 16:00:31 +00:00
}
impl CRDT for BucketParams {
fn merge(&mut self, o: &Self) {
self.authorized_keys.merge(&o.authorized_keys);
self.website.merge(&o.website);
}
}
2020-12-14 20:46:49 +00:00
impl BucketParams {
/// Initializes a new instance of the Bucket struct
2020-12-14 20:46:49 +00:00
pub fn new() -> Self {
BucketParams {
authorized_keys: crdt::LWWMap::new(),
2020-12-15 11:48:24 +00:00
website: crdt::LWW::new(false),
2020-12-14 20:46:49 +00:00
}
}
}
impl Bucket {
2021-03-26 20:53:28 +00:00
/// Create a new bucket
pub fn new(name: String) -> Self {
2020-11-20 22:20:20 +00:00
Bucket {
name,
2020-12-14 20:46:49 +00:00
state: crdt::LWW::new(BucketState::Present(BucketParams::new())),
2020-11-20 22:20:20 +00:00
}
}
2021-03-26 20:53:28 +00:00
/// Returns true if this represents a deleted bucket
pub fn is_deleted(&self) -> bool {
*self.state.get() == BucketState::Deleted
}
2021-03-26 20:53:28 +00:00
/// Return the list of authorized keys, when each was updated, and the permission associated to
/// the key
pub fn authorized_keys(&self) -> &[(String, u64, PermissionSet)] {
match self.state.get() {
BucketState::Deleted => &[],
2020-12-12 16:00:31 +00:00
BucketState::Present(state) => state.authorized_keys.items(),
}
2020-04-23 20:25:45 +00:00
}
}
impl Entry<EmptyKey, String> for Bucket {
fn partition_key(&self) -> &EmptyKey {
&EmptyKey
}
fn sort_key(&self) -> &String {
&self.name
}
}
impl CRDT for Bucket {
fn merge(&mut self, other: &Self) {
self.state.merge(&other.state);
}
}
pub struct BucketTable;
impl TableSchema for BucketTable {
type P = EmptyKey;
type S = String;
type E = Bucket;
type Filter = DeletedFilter;
fn matches_filter(entry: &Self::E, filter: &Self::Filter) -> bool {
filter.apply(entry.is_deleted())
}
}