Trait garage_table::replication::TableReplication

pub trait TableReplication: Send + Sync + 'static {
    type WriteSets: AsRef<Vec<Vec<Uuid>>> + AsMut<Vec<Vec<Uuid>>> + Send + Sync + 'static;

    // Required methods
    fn storage_nodes(&self, hash: &Hash) -> Vec<Uuid>;
    fn read_nodes(&self, hash: &Hash) -> Vec<Uuid>;
    fn read_quorum(&self) -> usize;
    fn write_sets(&self, hash: &Hash) -> Self::WriteSets;
    fn write_quorum(&self) -> usize;
    fn partition_of(&self, hash: &Hash) -> Partition;
    fn sync_partitions(&self) -> SyncPartitions;
}

Trait to describe how a table shall be replicated

Required Associated Types

type WriteSets: AsRef<Vec<Vec<Uuid>>> + AsMut<Vec<Vec<Uuid>>> + Send + Sync + 'static

Required Methods

fn storage_nodes(&self, hash: &Hash) -> Vec<Uuid>

The entire list of all nodes that store a partition

fn read_nodes(&self, hash: &Hash) -> Vec<Uuid>

Which nodes to send read requests to

fn read_quorum(&self) -> usize

Responses needed to consider a read succesfull

fn write_sets(&self, hash: &Hash) -> Self::WriteSets

Which nodes to send writes to

fn write_quorum(&self) -> usize

Responses needed to consider a write succesfull in each set

fn partition_of(&self, hash: &Hash) -> Partition

Get partition for data with given hash

fn sync_partitions(&self) -> SyncPartitions

List of partitions and nodes to sync with in current layout

Implementors

impl TableReplication for TableFullReplication

type WriteSets = Vec<Vec<FixedBytes32>>

impl TableReplication for TableShardedReplication

type WriteSets = WriteLock<Vec<Vec<FixedBytes32>>>