org.infinispan.distribution

Class LocalizedCacheTopology

java.lang.Object

org.infinispan.topology.CacheTopology

org.infinispan.distribution.LocalizedCacheTopology

public class LocalizedCacheTopology
extends CacheTopology

Extends CacheTopology with information about keys owned by the local node.

Since:

9.0

Author:

Dan Berindei

Nested Class Summary

Nested classes/interfaces inherited from class org.infinispan.topology.CacheTopology

CacheTopology.Externalizer, CacheTopology.Phase

Constructor Summary

Constructors

Constructor and Description
LocalizedCacheTopology(CacheMode cacheMode, CacheTopology cacheTopology, KeyPartitioner keyPartitioner, Address localAddress)

Method Summary

Modifier and Type	Method and Description
DistributionInfo	getDistribution(Object key)
DistributionInfo	getDistributionForSegment(int segmentId)
Address	getLocalAddress()
IntSet	getLocalReadSegments()
int	getSegment(Object key)
Collection<Address>	getWriteOwners(Collection<?> keys)
Collection<Address>	getWriteOwners(Object key)
boolean	isReadOwner(Object key)
boolean	isWriteOwner(Object key)
static LocalizedCacheTopology	makeSingletonTopology(CacheMode cacheMode, Address localAddress)

Methods inherited from class org.infinispan.topology.CacheTopology

equals, getActualMembers, getCurrentCH, getMembers, getMembersPersistentUUIDs, getPendingCH, getPhase, getReadConsistentHash, getRebalanceId, getTopologyId, getUnionCH, getWriteConsistentHash, hashCode, logRoutingTableInformation, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalizedCacheTopology

public LocalizedCacheTopology(CacheMode cacheMode,
                              CacheTopology cacheTopology,
                              KeyPartitioner keyPartitioner,
                              Address localAddress)

Method Detail

makeSingletonTopology

public static LocalizedCacheTopology makeSingletonTopology(CacheMode cacheMode,
                                                           Address localAddress)

isReadOwner

public boolean isReadOwner(Object key)

Returns:

true iff key key can be read without going remote.

isWriteOwner

public boolean isWriteOwner(Object key)

Returns:

true iff writing a value for key key will update it on the local node.

getSegment

public int getSegment(Object key)

Returns:

The consistent hash segment of key key

getDistributionForSegment

public DistributionInfo getDistributionForSegment(int segmentId)

Returns:

Information about the ownership of segment segment, including the primary owner.

getDistribution

public DistributionInfo getDistribution(Object key)

Returns:

Information about the ownership of key key, including the primary owner.

getWriteOwners

public Collection<Address> getWriteOwners(Object key)

Returns:

An unordered collection with the write owners of key.

getWriteOwners

public Collection<Address> getWriteOwners(Collection<?> keys)

Returns:

An unordered collection with the write owners of keys.

getLocalReadSegments

public IntSet getLocalReadSegments()

Returns:

The segments owned by the local node for reading.

getLocalAddress

public Address getLocalAddress()

Returns:

The address of the local node.