Package org.infinispan.container.versioning.irac

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 class	IracEntryVersion.MapEntry

Method Summary

Modifier and Type	Method	Description
InequalVersionComparisonResult	compareTo(IracEntryVersion other)	Compares this instance with another IracEntryVersion instance.
boolean	equals(Object o)
void	forEach(BiConsumer<ByteString,TopologyIracVersion> consumer)	Iterates over all entries of this version as pairs (site name, site version).
int	getTopology(ByteString siteName)
TopologyIracVersion	getVersion(ByteString siteName)
int	hashCode()
IracEntryVersion	increment(ByteString siteName, int topologyId)
IracEntryVersion	merge(IracEntryVersion other)
static IracEntryVersion	newVersion(ByteString site, TopologyIracVersion version)
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Details

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 - The BiConsumer.

compareTo

public InequalVersionComparisonResult compareTo(IracEntryVersion other)

Compares this instance with another IracEntryVersion instance.

Parameters:

other - The other IracEntryVersion instance.

Returns:

A InequalVersionComparisonResult instance 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)

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object