use std::sync::Arc; use garage_rpc::membership::System; use garage_rpc::ring::*; use garage_util::data::*; use crate::replication::*; #[derive(Clone)] pub struct TableFullReplication { pub system: Arc, pub max_faults: usize, } impl TableReplication for TableFullReplication { // Full replication schema: all nodes store everything // Writes are disseminated in an epidemic manner in the network // Advantage: do all reads locally, extremely fast // Inconvenient: only suitable to reasonably small tables fn read_nodes(&self, _hash: &Hash) -> Vec { vec![self.system.id] } fn read_quorum(&self) -> usize { 1 } fn write_nodes(&self, _hash: &Hash) -> Vec { let ring = self.system.ring.borrow(); ring.config.members.keys().cloned().collect::>() } fn write_quorum(&self) -> usize { let nmembers = self.system.ring.borrow().config.members.len(); if nmembers > self.max_faults { nmembers - self.max_faults } else { 1 } } fn max_write_errors(&self) -> usize { self.max_faults } fn partition_of(&self, _hash: &Hash) -> Partition { 0u16 } fn partitions(&self) -> Vec<(Partition, Hash)> { vec![(0u16, [0u8; 32].into())] } }