LWW Element Set is an algorithm under Conflict-free replicated data type(CRDT), here is the Python implementation.
LWW-Element-Set is similar to 2P-Set in that it consists of an "add set" and a "remove set", with a timestamp for each element. Elements are added to an LWW-Element-Set by inserting the element into the add set, with a timestamp. Elements are removed from the LWW-Element-Set by being added to the remove set, again with a timestamp. An element is a member of the LWW-Element-Set if it is in the add set, and either not in the remove set, or in the remove set but with an earlier timestamp than the latest timestamp in the add set. Merging two replicas of the LWW-Element-Set consists of taking the union of the add sets and the union of the remove sets. When timestamps are equal, the "bias" of the LWW-Element-Set comes into play. A LWW-Element-Set can be biased towards adds or removals. The advantage of LWW-Element-Set over 2P-Set is that, unlike 2P-Set, LWW-Element-Set allows an element to be reinserted after having been removed.
add
: Add a new element to LWWremove
: Remove element from LWWlookup
: Checks for the presence of an element in LWWcompare
: Checks if the given Lww is subset of another LWWmerge
: Merges 2 LWW and returns a new LWW
Run the following command before using the code:
pip install -r requirements.txt
Run the following code from the Project root:
pytest
For test coverage run from the Project root:
pytest --cov=LWW tests/
100%
Test coverage achieved.
See tests for examples.
This project is licensed under the MIT License - see the LICENSE.md file for details
Note : The code exploits the internal GIL available for built-in datatypes in Python and achieves,
further sychronization using RLock()
in Python.
The bias factor, for preference between add and remove is not implemented, and needs to be done.