Package org.infinispan.util

Class IracUtils

java.lang.Object

org.infinispan.util.IracUtils

public final class IracUtils
extends Object

Utility methods from IRAC (async cross-site replication)

Since:

12.0

Author:

Pedro Ruivo

Method Summary

Modifier and Type	Method	Description
static Optional<IracMetadata>	findIracMetadataFromCacheEntry(CacheEntry<?,?> entry)
static IracEntryVersion	getIracVersionFromCacheEntry(CacheEntry<?,?> entry)
static void	logUpdateDiscarded(Object key, IracMetadata metadata, LogSupplier logSupplier)
static void	setIracMetadata(CacheEntry<?,?> entry, int segment, IracMetadata metadata, IracTombstoneManager versionGenerator, LogSupplier logSupplier)	Stores the IracMetadata into CacheEntry.
static void	setPrivateMetadata(CacheEntry<?,?> entry, int segment, PrivateMetadata metadata, IracTombstoneManager versionGenerator, LogSupplier logSupplier)	Same as setIracMetadata(CacheEntry, int, IracMetadata, IracTombstoneManager, LogSupplier) but it stores a "full" PrivateMetadata instead of IracMetadata.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

findIracMetadataFromCacheEntry

public static Optional<IracMetadata> findIracMetadataFromCacheEntry(CacheEntry<?,?> entry)

getIracVersionFromCacheEntry

public static IracEntryVersion getIracVersionFromCacheEntry(CacheEntry<?,?> entry)

setIracMetadata

public static void setIracMetadata(CacheEntry<?,?> entry,
 int segment,
 IracMetadata metadata,
 IracTombstoneManager versionGenerator,
 LogSupplier logSupplier)

Stores the IracMetadata into CacheEntry.

If the CacheEntry is a remove, then the tombstone is added via IracTombstoneManager.storeTombstone(int, Object, IracMetadata).

Parameters:

entry - The CacheEntry to update.

metadata - The IracMetadata to store.

versionGenerator - The IracTombstoneManager to update.

logSupplier - The LogSupplier to log the IracMetadata and the key.

setPrivateMetadata

public static void setPrivateMetadata(CacheEntry<?,?> entry,
 int segment,
 PrivateMetadata metadata,
 IracTombstoneManager versionGenerator,
 LogSupplier logSupplier)

Same as setIracMetadata(CacheEntry, int, IracMetadata, IracTombstoneManager, LogSupplier) but it stores a "full" PrivateMetadata instead of IracMetadata.

This method is invoked to set the version from remote site updates. Note that the tombstone is not stored in case of a remove operation.

Parameters:

entry - The CacheEntry to update.

metadata - The PrivateMetadata to store.

versionGenerator - The IracTombstoneManager to update.

logSupplier - The LogSupplier to log the PrivateMetadata and the key.

logUpdateDiscarded

public static void logUpdateDiscarded(Object key,
 IracMetadata metadata,
 LogSupplier logSupplier)