greg/quoracle
1
0
Fork 0
Code Issues 1 Pull requests 1 Projects Releases Packages Wiki Activity Actions

Added capacity.

Browse source
This commit is contained in:
Michael Whittaker 2021-01-22 16:29:49 -08:00
parent 5ac22c8df6
commit 21deb75622
2 changed files with 13 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
quorums/quorum_system.py
View file

@ -117,6 +117,13 @@ class QuorumSystem(Generic[T]):
sigma = self.strategy(read_fraction, write_fraction, f) sigma = self.strategy(read_fraction, write_fraction, f)
return sigma.load(read_fraction, write_fraction) return sigma.load(read_fraction, write_fraction)
def capacity(self,
read_fraction: Optional[Distribution] = None,
write_fraction: Optional[Distribution] = None,
f: int = 0) \
-> float:
return 1 / self.load(read_fraction, write_fraction, f)
def _load_optimal_strategy(self, def _load_optimal_strategy(self,
read_quorums: List[Set[T]], read_quorums: List[Set[T]],
write_quorums: List[Set[T]], write_quorums: List[Set[T]],

6
quorums/strategy.py
View file

@ -16,6 +16,12 @@ class Strategy(Generic[T]):
-> float: -> float:
raise NotImplementedError raise NotImplementedError
def capacity(self,
read_fraction: Optional[Distribution] = None,
write_fraction: Optional[Distribution] = None) \
-> float:
return 1 / self.load(read_fraction, write_fraction)
def get_read_quorum(self) -> Set[T]: def get_read_quorum(self) -> Set[T]:
raise NotImplementedError raise NotImplementedError