Class IracEntryVersion
- java.lang.Object
-
- org.infinispan.container.versioning.irac.IracEntryVersion
-
@ProtoTypeId(1006) public class IracEntryVersion extends Object
An entry version for the IRAC algorithm (async cross site replication).It is represented as a vector clock where each site keeps it version.
The site version is composed as a pair (topology id, version).
- Since:
- 11.0
- Author:
- Pedro Ruivo
- See Also:
TopologyIracVersion
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classIracEntryVersion.MapEntry
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description InequalVersionComparisonResultcompareTo(IracEntryVersion other)Compares this instance with anotherIracEntryVersioninstance.booleanequals(Object o)voidforEach(BiConsumer<ByteString,TopologyIracVersion> consumer)Iterates over all entries of this version as pairs (site name, site version).intgetTopology(ByteString siteName)TopologyIracVersiongetVersion(ByteString siteName)inthashCode()IracEntryVersionincrement(ByteString siteName, int topologyId)IracEntryVersionmerge(IracEntryVersion other)static IracEntryVersionnewVersion(ByteString site, TopologyIracVersion version)StringtoString()
-
-
-
Method Detail
-
newVersion
public static IracEntryVersion newVersion(ByteString site, TopologyIracVersion version)
-
forEach
public void forEach(BiConsumer<ByteString,TopologyIracVersion> consumer)
Iterates over all entries of this version as pairs (site name, site version).- Parameters:
consumer- TheBiConsumer.
-
compareTo
public InequalVersionComparisonResult compareTo(IracEntryVersion other)
Compares this instance with anotherIracEntryVersioninstance.- Parameters:
other- The otherIracEntryVersioninstance.- Returns:
- A
InequalVersionComparisonResultinstance with the compare result.
-
merge
public IracEntryVersion merge(IracEntryVersion other)
-
getVersion
public TopologyIracVersion getVersion(ByteString siteName)
-
getTopology
public int getTopology(ByteString siteName)
-
increment
public IracEntryVersion increment(ByteString siteName, int topologyId)
-
-