Uses of Interface
org.infinispan.remoting.transport.Address

Packages that use Address

Package	Description
org.infinispan.affinity	This package contains the KeyAffinityService interfaces which allow user code to determine mapping of keys onto nodes
org.infinispan.affinity.impl
org.infinispan.commands	Commands that operate on the cache, either locally or remotely.
org.infinispan.conflict	This package contains the APIs that enable users to search for, and amend, data inconsistencies within their cache.
org.infinispan.container.entries	Entries which are stored in data containers.
org.infinispan.container.versioning.irac
org.infinispan.context	Contexts contain information of a specific invocation on the cache, such as its origins, scope (transactional or non-transactional), as well as invocation-specific flags.
org.infinispan.context.impl	This package contains different context implementations, selected dynamically based on the type of invocation.
org.infinispan.distribution	Classes relating to the distributed cache mode.
org.infinispan.distribution.ch	Consistent Hash interfaces
org.infinispan.distribution.ch.impl
org.infinispan.distribution.impl
org.infinispan.distribution.topologyaware
org.infinispan.manager	Cache manager API.
org.infinispan.manager.impl
org.infinispan.notifications.cachelistener.cluster
org.infinispan.notifications.cachelistener.cluster.impl
org.infinispan.notifications.cachelistener.event	invalid reference Cache -specific listener events
org.infinispan.notifications.cachelistener.event.impl
org.infinispan.notifications.cachemanagerlistener	invalid reference CacheManager -specific notifications and eventing.
org.infinispan.notifications.cachemanagerlistener.event	EmbeddedCacheManager-specific listener events
org.infinispan.notifications.cachemanagerlistener.event.impl
org.infinispan.partitionhandling.impl
org.infinispan.reactive.publisher.impl
org.infinispan.remoting.responses	Abstractions of the different response types allowed during RPC.
org.infinispan.remoting.rpc	Remote Procedure Call (RPC) interfaces and components used to invoke remote methods on cache instances.
org.infinispan.remoting.transport	Transports handle the low-level networking, used by the remoting components.
org.infinispan.remoting.transport.impl
org.infinispan.remoting.transport.jgroups	A transport implementation based on JGroups.
org.infinispan.server.hotrod
org.infinispan.server.hotrod.tx
org.infinispan.server.hotrod.tx.table
org.infinispan.stream.impl
org.infinispan.topology
org.infinispan.transaction.impl
org.infinispan.transaction.xa	XA transaction support.
org.infinispan.transaction.xa.recovery
org.infinispan.util.concurrent	Thread-safe containers and other concurrency-related utilities, designed to supplement JDK concurrency utilities and containers.
org.infinispan.xsite.irac
org.infinispan.xsite.response
org.infinispan.xsite.statetransfer
org.infinispan.xsite.status

Uses of Address in org.infinispan.affinity

Methods in org.infinispan.affinity with parameters of type Address

Modifier and Type	Method	Description
K	KeyAffinityService.getKeyForAddress(Address address)	Returns a key that will be distributed on the cluster node identified by address.

Method parameters in org.infinispan.affinity with type arguments of type Address

Modifier and Type	Method	Description
static <K, V> KeyAffinityService<K>	KeyAffinityServiceFactory.newKeyAffinityService(Cache<K,V> cache, Collection<Address> filter, KeyGenerator<K> keyGenerator, Executor ex, int keyBufferSize)	Same as KeyAffinityServiceFactory.newKeyAffinityService(org.infinispan.Cache, java.util.Collection, KeyGenerator, java.util.concurrent.Executor, int, boolean) with start == true.
static <K, V> KeyAffinityService<K>	KeyAffinityServiceFactory.newKeyAffinityService(Cache<K,V> cache, Collection<Address> filter, KeyGenerator<K> keyGenerator, Executor ex, int keyBufferSize, boolean start)	Creates a service that would only generate keys for addresses specified in filter.

Uses of Address in org.infinispan.affinity.impl

Methods in org.infinispan.affinity.impl that return types with arguments of type Address

Modifier and Type	Method	Description
Map<Address,BlockingQueue<K>>	KeyAffinityServiceImpl.getAddress2KeysMapping()

Methods in org.infinispan.affinity.impl with parameters of type Address

Modifier and Type	Method	Description
K	KeyAffinityServiceImpl.getKeyForAddress(Address address)

Constructor parameters in org.infinispan.affinity.impl with type arguments of type Address

Modifier	Constructor	Description
	KeyAffinityServiceImpl(Executor executor, Cache<? extends K,?> cache, KeyGenerator<? extends K> keyGenerator, int bufferSize, Collection<Address> filter, boolean start)

Uses of Address in org.infinispan.commands

Methods in org.infinispan.commands that return Address

Modifier and Type	Method	Description
Address	CommandInvocationId.getAddress()

Methods in org.infinispan.commands with parameters of type Address

Modifier and Type	Method	Description
org.infinispan.commands.write.InvalidateCommand	CommandsFactory.buildInvalidateFromL1Command(Address origin, long flagsBitSet, Collection<Object> keys)
org.infinispan.commands.write.InvalidateCommand	CommandsFactoryImpl.buildInvalidateFromL1Command(Address origin, long flagsBitSet, Collection<Object> keys)
static CommandInvocationId	CommandInvocationId.generateId(Address address)
default void	ReplicableCommand.setOrigin(Address origin)	Sets the sender's Address.

Uses of Address in org.infinispan.conflict

Methods in org.infinispan.conflict that return types with arguments of type Address

Modifier and Type	Method	Description
Map<Address,InternalCacheValue<V>>	ConflictManager.getAllVersions(K key)	Get all CacheEntry's that exists for a given key.
Stream<Map<Address,CacheEntry<K,V>>>	ConflictManager.getConflicts()	Returns a stream of conflicts detected in the cluster.

Uses of Address in org.infinispan.container.entries

Methods in org.infinispan.container.entries that return Address

Modifier and Type	Method	Description
Address	RemoteMetadata.getAddress()

Constructors in org.infinispan.container.entries with parameters of type Address

Modifier	Constructor	Description
	RemoteMetadata(Address address, EntryVersion version)

Uses of Address in org.infinispan.container.versioning.irac

Methods in org.infinispan.container.versioning.irac with parameters of type Address

Modifier and Type	Method	Description
void	DefaultIracTombstoneManager.sendStateTo(Address requestor, IntSet segments)
void	IracTombstoneManager.sendStateTo(Address requestor, IntSet segments)	Sends the tombstone belonging to the segments in segment to the originator
void	NoOpIracTombstoneManager.sendStateTo(Address requestor, IntSet segments)

Uses of Address in org.infinispan.context

Methods in org.infinispan.context that return Address

Modifier and Type	Method	Description
Address	InvocationContext.getOrigin()

Methods in org.infinispan.context with parameters of type Address

Modifier and Type	Method	Description
InvocationContext	InvocationContextFactory.createRemoteInvocationContext(Address origin)	Returns an NonTxInvocationContext whose AbstractInvocationContext.isOriginLocal() flag will be true.
InvocationContext	InvocationContextFactory.createRemoteInvocationContextForCommand(VisitableCommand cacheCommand, Address origin)	As InvocationContextFactory.createRemoteInvocationContext(org.infinispan.remoting.transport.Address), but returning the flags to the context from the Command if any Flag was set.
RemoteTxInvocationContext	InvocationContextFactory.createRemoteTxInvocationContext(RemoteTransaction tx, Address origin)	Returns an RemoteTxInvocationContext.

Uses of Address in org.infinispan.context.impl

Methods in org.infinispan.context.impl that return Address

Modifier and Type	Method	Description
final Address	AbstractInvocationContext.getOrigin()
Address	ImmutableContext.getOrigin()
Address	SingleKeyNonTxInvocationContext.getOrigin()

Methods in org.infinispan.context.impl that return types with arguments of type Address

Modifier and Type	Method	Description
final Collection<Address>	LocalTxInvocationContext.getRemoteLocksAcquired()

Methods in org.infinispan.context.impl with parameters of type Address

Modifier and Type	Method	Description
NonTxInvocationContext	NonTransactionalInvocationContextFactory.createRemoteInvocationContext(Address origin)
NonTxInvocationContext	TransactionalInvocationContextFactory.createRemoteInvocationContext(Address origin)
InvocationContext	AbstractInvocationContextFactory.createRemoteInvocationContextForCommand(VisitableCommand cacheCommand, Address origin)
RemoteTxInvocationContext	NonTransactionalInvocationContextFactory.createRemoteTxInvocationContext(RemoteTransaction tx, Address origin)
RemoteTxInvocationContext	TransactionalInvocationContextFactory.createRemoteTxInvocationContext(RemoteTransaction tx, Address origin)
protected final NonTxInvocationContext	TransactionalInvocationContextFactory.newNonTxInvocationContext(Address origin)

Method parameters in org.infinispan.context.impl with type arguments of type Address

Modifier and Type	Method	Description
final void	LocalTxInvocationContext.remoteLocksAcquired(Collection<Address> nodes)

Constructors in org.infinispan.context.impl with parameters of type Address

Modifier	Constructor	Description
protected	AbstractInvocationContext(Address origin)
protected	AbstractTxInvocationContext(T cacheTransaction, Address origin)
	ClearInvocationContext(Address origin)
	NonTxInvocationContext(int numEntries, Address origin)
	NonTxInvocationContext(Address origin)
	SingleKeyNonTxInvocationContext(Address origin)

Uses of Address in org.infinispan.distribution

Methods in org.infinispan.distribution that return Address

Modifier and Type	Method	Description
Address	LocalizedCacheTopology.getLocalAddress()
Address	DistributionInfo.primary()

Methods in org.infinispan.distribution that return types with arguments of type Address

Modifier and Type	Method	Description
Set<Address>	LocalizedCacheTopology.getMembersSet()
Collection<Address>	LocalizedCacheTopology.getWriteOwners(Object key)
Collection<Address>	LocalizedCacheTopology.getWriteOwners(Collection<?> keys)
List<Address>	DistributionInfo.readOwners()
Collection<Address>	DistributionInfo.writeBackups()
List<Address>	DistributionInfo.writeOwners()

Methods in org.infinispan.distribution with parameters of type Address

Modifier and Type	Method	Description
void	L1Manager.addRequestor(Object key, Address requestor)	Records a request that will be cached in another nodes L1
CompletableFuture<?>	L1Manager.flushCache(Collection<Object> key, Address origin, boolean assumeOriginKeptEntryInL1)
static LocalizedCacheTopology	LocalizedCacheTopology.makeSegmentedSingletonTopology(KeyPartitioner keyPartitioner, int numSegments, Address localAddress)	Creates a new local topology that has a single address but multiple segments.
static LocalizedCacheTopology	LocalizedCacheTopology.makeSingletonTopology(CacheMode cacheMode, Address localAddress)

Constructors in org.infinispan.distribution with parameters of type Address

Modifier	Constructor	Description
	DistributionInfo(int segmentId, Address primary, List<Address> readOwners, List<Address> writeOwners, Collection<Address> writeBackups, Address localAddress)
	LocalizedCacheTopology(CacheMode cacheMode, CacheTopology cacheTopology, KeyPartitioner keyPartitioner, Address localAddress, boolean connected)

Constructor parameters in org.infinispan.distribution with type arguments of type Address

Modifier	Constructor	Description
	DistributionInfo(int segmentId, Address primary, List<Address> readOwners, List<Address> writeOwners, Collection<Address> writeBackups, Address localAddress)
	DistributionInfo(int segmentId, Address primary, List<Address> readOwners, List<Address> writeOwners, Collection<Address> writeBackups, Address localAddress)

Uses of Address in org.infinispan.distribution.ch

Methods in org.infinispan.distribution.ch that return Address

Modifier and Type	Method	Description
Address	ConsistentHash.locatePrimaryOwnerForSegment(int segmentId)

Methods in org.infinispan.distribution.ch that return types with arguments of type Address

Modifier and Type	Method	Description
default Map<Address,Float>	ConsistentHash.getCapacityFactors()	The capacity factor of each member.
List<Address>	ConsistentHash.getMembers()	Should return the addresses of the nodes used to create this consistent hash.
List<Address>	ConsistentHash.locateOwnersForSegment(int segmentId)

Methods in org.infinispan.distribution.ch with parameters of type Address

Modifier and Type	Method	Description
Set<Integer>	ConsistentHash.getPrimarySegmentsForOwner(Address owner)	Returns the segments that this cache member is the primary owner for.
Set<Integer>	ConsistentHash.getSegmentsForOwner(Address owner)	Returns the segments owned by a cache member.
default boolean	ConsistentHash.isSegmentLocalToNode(Address nodeAddress, int segmentId)	Check if a segment is local to a given member.

Method parameters in org.infinispan.distribution.ch with type arguments of type Address

Modifier and Type	Method	Description
CH	ConsistentHashFactory.create(int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)	Deprecated, for removal: This API element is subject to removal in a future version. Create a new consistent hash instance.
CH	ConsistentHashFactory.create(int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)	Deprecated, for removal: This API element is subject to removal in a future version. Create a new consistent hash instance.
default CH	ConsistentHashFactory.create(Hash hashFunction, int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)	Deprecated, for removal: This API element is subject to removal in a future version. since 11.0.
default CH	ConsistentHashFactory.create(Hash hashFunction, int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)	Deprecated, for removal: This API element is subject to removal in a future version. since 11.0.
default ConsistentHash	ConsistentHash.remapAddresses(UnaryOperator<Address> remapper)	Returns a new ConsistentHash with the addresses remapped according to the provided UnaryOperator.
default ConsistentHash	ConsistentHash.remapAddressRemoveMissing(UnaryOperator<Address> remapper)	Same as ConsistentHash.remapAddresses(UnaryOperator) but skip missing members.
CH	ConsistentHashFactory.updateMembers(CH baseCH, List<Address> newMembers, Map<Address,Float> capacityFactors)	Deprecated, for removal: This API element is subject to removal in a future version. Updates an existing consistent hash instance to remove owners that are not in the newMembers list.
CH	ConsistentHashFactory.updateMembers(CH baseCH, List<Address> newMembers, Map<Address,Float> capacityFactors)	Deprecated, for removal: This API element is subject to removal in a future version. Updates an existing consistent hash instance to remove owners that are not in the newMembers list.

Uses of Address in org.infinispan.distribution.ch.impl

Fields in org.infinispan.distribution.ch.impl with type parameters of type Address

Modifier and Type	Field	Description
protected final Map<Address,Float>	AbstractConsistentHashFactory.Builder.capacityFactors
protected final List<Address>	AbstractConsistentHash.members	The membership of the cache topology that uses this CH.
protected final List<Address>	AbstractConsistentHashFactory.Builder.members

Methods in org.infinispan.distribution.ch.impl that return Address

Modifier and Type	Method	Description
protected Address	DefaultConsistentHashFactory.findNewBackupOwner(DefaultConsistentHashFactory.Builder builder, Collection<Address> excludes, Address owner)
protected Address	AbstractConsistentHashFactory.findNewPrimaryOwner(org.infinispan.distribution.ch.impl.AbstractConsistentHashFactory.Builder builder, Collection<Address> candidates, Address primaryOwner)
protected Address	AbstractConsistentHashFactory.findWorstPrimaryOwner(org.infinispan.distribution.ch.impl.AbstractConsistentHashFactory.Builder builder, List<Address> nodes)
Address	DefaultConsistentHashFactory.Builder.getPrimaryOwner(int segment)
Address	DefaultConsistentHash.locatePrimaryOwnerForSegment(int segmentId)
Address	ReplicatedConsistentHash.locatePrimaryOwnerForSegment(int segmentId)

Methods in org.infinispan.distribution.ch.impl that return types with arguments of type Address

Modifier and Type	Method	Description
List<Address>	DefaultConsistentHashFactory.Builder.getBackupOwners(int segment)
Map<Address,Float>	AbstractConsistentHash.getCapacityFactors()
Map<Address,Float>	ReplicatedConsistentHash.getCapacityFactors()
List<Address>	AbstractConsistentHash.getMembers()
List<Address>	ReplicatedConsistentHash.getMembers()
List<Address>	DefaultConsistentHashFactory.Builder.getOwners(int segment)
List<Address>	DefaultConsistentHash.locateOwnersForSegment(int segmentId)
List<Address>	ReplicatedConsistentHash.locateOwnersForSegment(int segmentId)
protected static List<Address>	AbstractConsistentHash.parseMembers(ScopedPersistentState state)
protected Map<Address,Float>	AbstractConsistentHash.remapCapacityFactors(UnaryOperator<Address> remapper, boolean allowMissing)
protected List<Address>	AbstractConsistentHash.remapMembers(UnaryOperator<Address> remapper, boolean allowMissing)
protected Map<Address,Float>	AbstractConsistentHash.unionCapacityFactors(AbstractConsistentHash ch2)

Methods in org.infinispan.distribution.ch.impl with parameters of type Address

Modifier and Type	Method	Description
boolean	DefaultConsistentHashFactory.Builder.addOwner(int segment, Address owner)
void	DefaultConsistentHashFactory.Builder.addPrimaryOwner(int segment, Address newPrimaryOwner)
void	OwnershipStatistics.decOwned(Address a)
void	OwnershipStatistics.decPrimaryOwned(Address a)
protected Address	DefaultConsistentHashFactory.findNewBackupOwner(DefaultConsistentHashFactory.Builder builder, Collection<Address> excludes, Address owner)
protected Address	AbstractConsistentHashFactory.findNewPrimaryOwner(org.infinispan.distribution.ch.impl.AbstractConsistentHashFactory.Builder builder, Collection<Address> candidates, Address primaryOwner)
int	DefaultConsistentHashFactory.Builder.getOwned(Address node)
int	OwnershipStatistics.getOwned(Address a)
int	DefaultConsistentHashFactory.Builder.getPrimaryOwned(Address node)
int	OwnershipStatistics.getPrimaryOwned(Address a)
Set<Integer>	DefaultConsistentHash.getPrimarySegmentsForOwner(Address owner)
Set<Integer>	ReplicatedConsistentHash.getPrimarySegmentsForOwner(Address owner)
Set<Integer>	DefaultConsistentHash.getSegmentsForOwner(Address owner)
Set<Integer>	ReplicatedConsistentHash.getSegmentsForOwner(Address owner)
void	OwnershipStatistics.incOwned(Address a)
void	OwnershipStatistics.incPrimaryOwned(Address a)
boolean	DefaultConsistentHash.isSegmentLocalToNode(Address nodeAddress, int segmentId)
boolean	ReplicatedConsistentHash.isSegmentLocalToNode(Address nodeAddress, int segmentId)
boolean	DefaultConsistentHashFactory.Builder.removeOwner(int segment, Address owner)
void	DefaultConsistentHashFactory.Builder.replacePrimaryOwnerWithBackup(int segment, Address newPrimaryOwner)

Method parameters in org.infinispan.distribution.ch.impl with type arguments of type Address

Modifier and Type	Method	Description
boolean	DefaultConsistentHashFactory.Builder.addOwners(int segment, Collection<Address> newOwners)
protected void	AbstractConsistentHashFactory.checkCapacityFactors(List<Address> members, Map<Address,Float> capacityFactors)
protected void	AbstractConsistentHashFactory.checkCapacityFactors(List<Address> members, Map<Address,Float> capacityFactors)
int	DefaultConsistentHashFactory.Builder.computeActualNumOwners(int numOwners, List<Address> members, Map<Address,Float> capacityFactors)
int	DefaultConsistentHashFactory.Builder.computeActualNumOwners(int numOwners, List<Address> members, Map<Address,Float> capacityFactors)
DefaultConsistentHash	DefaultConsistentHashFactory.create(int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
DefaultConsistentHash	DefaultConsistentHashFactory.create(int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
ReplicatedConsistentHash	ReplicatedConsistentHashFactory.create(int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
ReplicatedConsistentHash	ReplicatedConsistentHashFactory.create(int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
DefaultConsistentHash	SyncConsistentHashFactory.create(int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
DefaultConsistentHash	SyncConsistentHashFactory.create(int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
ReplicatedConsistentHash	SyncReplicatedConsistentHashFactory.create(int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
ReplicatedConsistentHash	SyncReplicatedConsistentHashFactory.create(int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
protected TopologyAwareSyncConsistentHashFactory.Builder	TopologyAwareSyncConsistentHashFactory.createBuilder(int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
protected TopologyAwareSyncConsistentHashFactory.Builder	TopologyAwareSyncConsistentHashFactory.createBuilder(int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
protected Address	DefaultConsistentHashFactory.findNewBackupOwner(DefaultConsistentHashFactory.Builder builder, Collection<Address> excludes, Address owner)
protected Address	AbstractConsistentHashFactory.findNewPrimaryOwner(org.infinispan.distribution.ch.impl.AbstractConsistentHashFactory.Builder builder, Collection<Address> candidates, Address primaryOwner)
protected Address	AbstractConsistentHashFactory.findWorstPrimaryOwner(org.infinispan.distribution.ch.impl.AbstractConsistentHashFactory.Builder builder, List<Address> nodes)
protected static void	AbstractConsistentHash.mergeLists(List<Address> dest, List<Address> src)	Adds all elements from src list that do not already exist in dest list to the latter.
ConsistentHash	DefaultConsistentHash.remapAddresses(UnaryOperator<Address> remapper)
ConsistentHash	ReplicatedConsistentHash.remapAddresses(UnaryOperator<Address> remapper)
ConsistentHash	DefaultConsistentHash.remapAddressRemoveMissing(UnaryOperator<Address> remapper)
protected Map<Address,Float>	AbstractConsistentHash.remapCapacityFactors(UnaryOperator<Address> remapper, boolean allowMissing)
protected List<Address>	AbstractConsistentHash.remapMembers(UnaryOperator<Address> remapper, boolean allowMissing)
DefaultConsistentHash	DefaultConsistentHashFactory.updateMembers(DefaultConsistentHash baseCH, List<Address> actualMembers, Map<Address,Float> actualCapacityFactors)	Leavers are removed and segments without owners are assigned new owners.
DefaultConsistentHash	DefaultConsistentHashFactory.updateMembers(DefaultConsistentHash baseCH, List<Address> actualMembers, Map<Address,Float> actualCapacityFactors)	Leavers are removed and segments without owners are assigned new owners.
ReplicatedConsistentHash	ReplicatedConsistentHashFactory.updateMembers(ReplicatedConsistentHash baseCH, List<Address> newMembers, Map<Address,Float> actualCapacityFactors)
ReplicatedConsistentHash	ReplicatedConsistentHashFactory.updateMembers(ReplicatedConsistentHash baseCH, List<Address> newMembers, Map<Address,Float> actualCapacityFactors)
DefaultConsistentHash	SyncConsistentHashFactory.updateMembers(DefaultConsistentHash baseCH, List<Address> newMembers, Map<Address,Float> actualCapacityFactors)
DefaultConsistentHash	SyncConsistentHashFactory.updateMembers(DefaultConsistentHash baseCH, List<Address> newMembers, Map<Address,Float> actualCapacityFactors)
ReplicatedConsistentHash	SyncReplicatedConsistentHashFactory.updateMembers(ReplicatedConsistentHash baseCH, List<Address> newMembers, Map<Address,Float> actualCapacityFactors)
ReplicatedConsistentHash	SyncReplicatedConsistentHashFactory.updateMembers(ReplicatedConsistentHash baseCH, List<Address> newMembers, Map<Address,Float> actualCapacityFactors)

Constructor parameters in org.infinispan.distribution.ch.impl with type arguments of type Address

Modifier	Constructor	Description
protected	AbstractConsistentHash(int numSegments, List<Address> members, float[] capacityFactors)
protected	AbstractConsistentHash(int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
protected	AbstractConsistentHash(int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
	Builder(int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
	Builder(int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
	Builder(DefaultConsistentHash baseCH, List<Address> actualMembers, Map<Address,Float> actualCapacityFactors)
	Builder(DefaultConsistentHash baseCH, List<Address> actualMembers, Map<Address,Float> actualCapacityFactors)
protected	Builder(int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
protected	Builder(int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
	DefaultConsistentHash(int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors, List<Address>[] segmentOwners)
	DefaultConsistentHash(int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors, List<Address>[] segmentOwners)
	OwnershipStatistics(List<Address> nodes)
	OwnershipStatistics(ConsistentHash ch, List<Address> activeNodes)
	ReplicatedConsistentHash(List<Address> members, int[] primaryOwners)
	ReplicatedConsistentHash(List<Address> members, Map<Address,Float> capacityFactors, List<Address> membersWithoutState, int[] primaryOwners)
	ReplicatedConsistentHash(List<Address> members, Map<Address,Float> capacityFactors, List<Address> membersWithoutState, int[] primaryOwners)

Uses of Address in org.infinispan.distribution.impl

Methods in org.infinispan.distribution.impl with parameters of type Address

Modifier and Type	Method	Description
void	L1ManagerImpl.addRequestor(Object key, Address origin)
CompletableFuture<?>	L1ManagerImpl.flushCache(Collection<Object> keys, Address origin, boolean assumeOriginKeptEntryInL1)
static LocalizedCacheTopology	DistributionManagerImpl.makeSingletonTopology(CacheMode cacheMode, KeyPartitioner keyPartitioner, int numSegments, Address localAddress)

Uses of Address in org.infinispan.distribution.topologyaware

Methods in org.infinispan.distribution.topologyaware that return types with arguments of type Address

Modifier and Type	Method	Description
Collection<Address>	TopologyInfo.getMachineNodes(String site, String rack, String machine)
Collection<Address>	TopologyInfo.getRackNodes(String site, String rack)
Collection<Address>	TopologyInfo.getSiteNodes(String site)

Methods in org.infinispan.distribution.topologyaware with parameters of type Address

Modifier and Type	Method	Description
boolean	TopologyInfo.duplicateLocation(TopologyLevel level, Collection<Address> addresses, Address candidate, boolean excludeCandidate)
float	TopologyInfo.getExpectedOwnedSegments(Address address)
float	TopologyInfo.getExpectedPrimarySegments(Address address)
Object	TopologyInfo.getLocationId(TopologyLevel level, Address address)
int	TopologyInfo.getMachineIndex(Address address)
int	TopologyInfo.getRackIndex(Address address)
int	TopologyInfo.getSiteIndex(Address address)

Method parameters in org.infinispan.distribution.topologyaware with type arguments of type Address

Modifier and Type	Method	Description
float	TopologyInfo.computeTotalCapacity(Collection<Address> nodes, Map<Address,Float> capacityFactors)
float	TopologyInfo.computeTotalCapacity(Collection<Address> nodes, Map<Address,Float> capacityFactors)
boolean	TopologyInfo.duplicateLocation(TopologyLevel level, Collection<Address> addresses, Address candidate, boolean excludeCandidate)
int	TopologyInfo.getDistinctLocationsCount(TopologyLevel level, Collection<Address> addresses)

Constructor parameters in org.infinispan.distribution.topologyaware with type arguments of type Address

Modifier	Constructor	Description
	TopologyInfo(int numSegments, int numOwners, Collection<Address> members, Map<Address,Float> capacityFactors)
	TopologyInfo(int numSegments, int numOwners, Collection<Address> members, Map<Address,Float> capacityFactors)

Uses of Address in org.infinispan.manager

Methods in org.infinispan.manager that return Address

Modifier and Type	Method	Description
Address	DefaultCacheManager.getAddress()	Warning: the address may be null before the first clustered cache starts and after all the clustered caches have been stopped.
Address	EmbeddedCacheManager.getAddress()	Warning: the address may be null before the first clustered cache starts and after all the clustered caches have been stopped.
Address	DefaultCacheManager.getCoordinator()
Address	EmbeddedCacheManager.getCoordinator()

Methods in org.infinispan.manager that return types with arguments of type Address

Modifier and Type	Method	Description
List<Address>	DefaultCacheManager.getMembers()
List<Address>	EmbeddedCacheManager.getMembers()

Method parameters in org.infinispan.manager with type arguments of type Address

Modifier and Type	Method	Description
ClusterExecutor	ClusterExecutor.filterTargets(Collection<Address> addresses)	Allows for filtering of address nodes by only allowing addresses in this collection from being contacted.
ClusterExecutor	ClusterExecutor.filterTargets(Predicate<? super Address> predicate)	Allows for filtering of address nodes dynamically per invocation.
ClusterExecutor	ClusterExecutor.filterTargets(ClusterExecutionPolicy policy, Predicate<? super Address> predicate)	Allows for filtering of address nodes dynamically per invocation.
<V> CompletableFuture<Void>	ClusterExecutor.submitConsumer(Function<? super EmbeddedCacheManager,? extends V> callable, TriConsumer<? super Address,? super V,? super Throwable> triConsumer)	Submits the given command to the desired nodes and allows for handling of results as they return.
default <V> CompletableFuture<Void>	ClusterExecutor.submitConsumer(SerializableFunction<? super EmbeddedCacheManager,? extends V> callable, TriConsumer<? super Address,? super V,? super Throwable> triConsumer)	The same as ClusterExecutor.submitConsumer(Function, TriConsumer), except the Callable must also implement Serializable.

Uses of Address in org.infinispan.manager.impl

Methods in org.infinispan.manager.impl that return Address

Modifier and Type	Method	Description
Address	AbstractDelegatingEmbeddedCacheManager.getAddress()
Address	AbstractDelegatingEmbeddedCacheManager.getCoordinator()

Methods in org.infinispan.manager.impl that return types with arguments of type Address

Modifier and Type	Method	Description
List<Address>	AbstractDelegatingEmbeddedCacheManager.getMembers()

Method parameters in org.infinispan.manager.impl with type arguments of type Address

Modifier and Type	Method	Description
static ClusterExecutor	ClusterExecutors.allSubmissionExecutor(Predicate<? super Address> predicate, EmbeddedCacheManager manager, Transport transport, long time, TimeUnit unit, BlockingManager bm, ScheduledExecutorService timeoutExecutor)
static ClusterExecutor	ClusterExecutors.singleNodeSubmissionExecutor(Predicate<? super Address> predicate, EmbeddedCacheManager manager, Transport transport, long time, TimeUnit unit, BlockingManager bm, ScheduledExecutorService timeoutExecutor, int failOverCount)

Uses of Address in org.infinispan.notifications.cachelistener.cluster

Methods in org.infinispan.notifications.cachelistener.cluster that return Address

Modifier and Type	Method	Description
Address	RemoteClusterListener.getOwnerAddress()

Methods in org.infinispan.notifications.cachelistener.cluster with parameters of type Address

Modifier and Type	Method	Description
void	ClusterEventManager.addEvents(Object batchIdentifier, Address target, UUID identifier, Collection<ClusterEvent<K,V>> events, boolean sync)	Adds additional cluster events that need to be sent remotely for an event originating locally.

Constructors in org.infinispan.notifications.cachelistener.cluster with parameters of type Address

Modifier	Constructor	Description
	ClusterListenerReplicateCallable(String cacheName, UUID identifier, Address origin, CacheEventFilter<K,V> filter, CacheEventConverter<K,V,?> converter, boolean sync, Set<Class<? extends Annotation>> filterAnnotations, DataConversion keyDataConversion, DataConversion valueDataConversion, boolean useStorageFormat)
	RemoteClusterListener(UUID id, Address origin, CacheNotifier cacheNotifier, CacheManagerNotifier cacheManagerNotifier, ClusterEventManager eventManager, boolean sync)

Uses of Address in org.infinispan.notifications.cachelistener.cluster.impl

Fields in org.infinispan.notifications.cachelistener.cluster.impl with type parameters of type Address

Modifier and Type	Field	Description
protected final Map<Address,org.infinispan.notifications.cachelistener.cluster.impl.BatchingClusterEventManagerImpl.TargetEvents<K,V>>	BatchingClusterEventManagerImpl.UnicastEventContext.targets

Methods in org.infinispan.notifications.cachelistener.cluster.impl with parameters of type Address

Modifier and Type	Method	Description
void	BatchingClusterEventManagerImpl.addEvents(Object batchIdentifier, Address target, UUID identifier, Collection<ClusterEvent<K,V>> events, boolean sync)
void	ClusterEventManagerStub.addEvents(Object batchIdentifier, Address target, UUID identifier, Collection<ClusterEvent<K,V>> clusterEvents, boolean sync)
void	BatchingClusterEventManagerImpl.UnicastEventContext.addTargets(Address address, UUID identifier, Collection<ClusterEvent<K,V>> events, boolean sync)

Uses of Address in org.infinispan.notifications.cachelistener.event

Methods in org.infinispan.notifications.cachelistener.event that return types with arguments of type Address

Modifier and Type	Method	Description
Collection<Address>	DataRehashedEvent.getMembersAtEnd()
Collection<Address>	DataRehashedEvent.getMembersAtStart()

Uses of Address in org.infinispan.notifications.cachelistener.event.impl

Methods in org.infinispan.notifications.cachelistener.event.impl that return types with arguments of type Address

Modifier and Type	Method	Description
Collection<Address>	EventImpl.getMembersAtEnd()
Collection<Address>	EventImpl.getMembersAtStart()

Uses of Address in org.infinispan.notifications.cachemanagerlistener

Methods in org.infinispan.notifications.cachemanagerlistener with parameters of type Address

Modifier and Type	Method	Description
CompletionStage<Void>	CacheManagerNotifier.notifyMerge(List<Address> members, List<Address> oldMembers, Address myAddress, int viewId, List<List<Address>> subgroupsMerged)
CompletionStage<Void>	CacheManagerNotifierImpl.notifyMerge(List<Address> members, List<Address> oldMembers, Address myAddress, int viewId, List<List<Address>> subgroupsMerged)
CompletionStage<Void>	CacheManagerNotifier.notifyViewChange(List<Address> members, List<Address> oldMembers, Address myAddress, int viewId)	Notifies all registered listeners of a viewChange event.
CompletionStage<Void>	CacheManagerNotifierImpl.notifyViewChange(List<Address> members, List<Address> oldMembers, Address myAddress, int viewId)

Method parameters in org.infinispan.notifications.cachemanagerlistener with type arguments of type Address

Modifier and Type	Method	Description
CompletionStage<Void>	CacheManagerNotifier.notifyMerge(List<Address> members, List<Address> oldMembers, Address myAddress, int viewId, List<List<Address>> subgroupsMerged)
CompletionStage<Void>	CacheManagerNotifierImpl.notifyMerge(List<Address> members, List<Address> oldMembers, Address myAddress, int viewId, List<List<Address>> subgroupsMerged)
CompletionStage<Void>	CacheManagerNotifier.notifyViewChange(List<Address> members, List<Address> oldMembers, Address myAddress, int viewId)	Notifies all registered listeners of a viewChange event.
CompletionStage<Void>	CacheManagerNotifierImpl.notifyViewChange(List<Address> members, List<Address> oldMembers, Address myAddress, int viewId)

Uses of Address in org.infinispan.notifications.cachemanagerlistener.event

Methods in org.infinispan.notifications.cachemanagerlistener.event that return Address

Modifier and Type	Method	Description
Address	ViewChangedEvent.getLocalAddress()

Methods in org.infinispan.notifications.cachemanagerlistener.event that return types with arguments of type Address

Modifier and Type	Method	Description
List<Address>	ViewChangedEvent.getNewMembers()	Gets the current list of members.
List<Address>	ViewChangedEvent.getOldMembers()	Gets the previous list of members.
List<List<Address>>	MergeEvent.getSubgroupsMerged()

Uses of Address in org.infinispan.notifications.cachemanagerlistener.event.impl

Methods in org.infinispan.notifications.cachemanagerlistener.event.impl that return Address

Modifier and Type	Method	Description
Address	EventImpl.getLocalAddress()

Methods in org.infinispan.notifications.cachemanagerlistener.event.impl that return types with arguments of type Address

Modifier and Type	Method	Description
List<Address>	EventImpl.getNewMembers()
List<Address>	EventImpl.getOldMembers()
List<List<Address>>	EventImpl.getSubgroupsMerged()

Methods in org.infinispan.notifications.cachemanagerlistener.event.impl with parameters of type Address

Modifier and Type	Method	Description
void	EventImpl.setLocalAddress(Address localAddress)

Method parameters in org.infinispan.notifications.cachemanagerlistener.event.impl with type arguments of type Address

Modifier and Type	Method	Description
void	EventImpl.setNewMembers(List<Address> newMembers)
void	EventImpl.setOldMembers(List<Address> oldMembers)
void	EventImpl.setSubgroupsMerged(List<List<Address>> subgroupsMerged)

Constructors in org.infinispan.notifications.cachemanagerlistener.event.impl with parameters of type Address

Modifier	Constructor	Description
	EventImpl(String cacheName, EmbeddedCacheManager cacheManager, Event.Type type, List<Address> newMemberList, List<Address> oldMemberList, Address localAddress, int viewId)

Constructor parameters in org.infinispan.notifications.cachemanagerlistener.event.impl with type arguments of type Address

Modifier	Constructor	Description
	EventImpl(String cacheName, EmbeddedCacheManager cacheManager, Event.Type type, List<Address> newMemberList, List<Address> oldMemberList, Address localAddress, int viewId)

Uses of Address in org.infinispan.partitionhandling.impl

Methods in org.infinispan.partitionhandling.impl that return types with arguments of type Address

Modifier and Type	Method	Description
Map<Address,Float>	AvailabilityStrategyContext.getCapacityFactors()
List<Address>	AvailabilityStrategyContext.getExpectedMembers()	The members of the cache.

Methods in org.infinispan.partitionhandling.impl with parameters of type Address

Modifier and Type	Method	Description
void	AvailabilityStrategy.onGracefulLeave(AvailabilityStrategyContext context, Address leaver)	Called when a node leaves gracefully.
void	PreferAvailabilityStrategy.onGracefulLeave(AvailabilityStrategyContext context, Address leaver)
void	PreferConsistencyStrategy.onGracefulLeave(AvailabilityStrategyContext context, Address leaver)
void	AvailabilityStrategy.onJoin(AvailabilityStrategyContext context, Address joiner)	Called when a node joins.
void	PreferAvailabilityStrategy.onJoin(AvailabilityStrategyContext context, Address joiner)
void	PreferConsistencyStrategy.onJoin(AvailabilityStrategyContext context, Address joiner)

Method parameters in org.infinispan.partitionhandling.impl with type arguments of type Address

Modifier and Type	Method	Description
boolean	AvailablePartitionHandlingManager.addPartialCommit1PCTransaction(GlobalTransaction globalTransaction, Collection<Address> affectedNodes, Collection<Object> lockedKeys, List<org.infinispan.commands.write.WriteCommand> modifications)
boolean	PartitionHandlingManager.addPartialCommit1PCTransaction(GlobalTransaction globalTransaction, Collection<Address> affectedNodes, Collection<Object> lockedKeys, List<org.infinispan.commands.write.WriteCommand> modifications)	Adds a partially committed transaction.
boolean	PartitionHandlingManagerImpl.addPartialCommit1PCTransaction(GlobalTransaction globalTransaction, Collection<Address> affectedNodes, Collection<Object> lockedKeys, List<org.infinispan.commands.write.WriteCommand> modifications)
boolean	AvailablePartitionHandlingManager.addPartialCommit2PCTransaction(GlobalTransaction globalTransaction, Collection<Address> affectedNodes, Collection<Object> lockedKeys, Map<Object,IncrementableEntryVersion> newVersions)
boolean	PartitionHandlingManager.addPartialCommit2PCTransaction(GlobalTransaction globalTransaction, Collection<Address> affectedNodes, Collection<Object> lockedKeys, Map<Object,IncrementableEntryVersion> newVersions)	Adds a partially committed transaction.
boolean	PartitionHandlingManagerImpl.addPartialCommit2PCTransaction(GlobalTransaction globalTransaction, Collection<Address> affectedNodes, Collection<Object> lockedKeys, Map<Object,IncrementableEntryVersion> newVersions)
boolean	AvailablePartitionHandlingManager.addPartialRollbackTransaction(GlobalTransaction globalTransaction, Collection<Address> affectedNodes, Collection<Object> lockedKeys)
boolean	PartitionHandlingManager.addPartialRollbackTransaction(GlobalTransaction globalTransaction, Collection<Address> affectedNodes, Collection<Object> lockedKeys)	Adds a partially aborted transaction.
boolean	PartitionHandlingManagerImpl.addPartialRollbackTransaction(GlobalTransaction globalTransaction, Collection<Address> affectedNodes, Collection<Object> lockedKeys)
ConsistentHash	AvailabilityStrategyContext.calculateConflictHash(ConsistentHash preferredHash, Set<ConsistentHash> distinctHashes, List<Address> actualMembers)
CacheTopology	PreferAvailabilityStrategy.computePreferredTopology(Map<Address,CacheStatusResponse> statusResponseMap)	Ignore the AvailabilityStrategyContext and only compute the preferred topology for testing.
protected boolean	PreferConsistencyStrategy.isMinorityPartition(List<Address> stableMembers, List<Address> lostMembers)
void	AvailabilityStrategyContext.manuallyUpdateAvailabilityMode(List<Address> actualMembers, AvailabilityMode mode, boolean cancelRebalance)	Enter a new availability mode manually.
void	AvailabilityStrategy.onClusterViewChange(AvailabilityStrategyContext context, List<Address> clusterMembers)	Called when the cluster view changed (e.g.
void	PreferAvailabilityStrategy.onClusterViewChange(AvailabilityStrategyContext context, List<Address> clusterMembers)
void	PreferConsistencyStrategy.onClusterViewChange(AvailabilityStrategyContext context, List<Address> clusterMembers)
void	AvailabilityStrategy.onPartitionMerge(AvailabilityStrategyContext context, Map<Address,CacheStatusResponse> statusResponseMap)	Called when two or more partitions merge, to compute the stable and current cache topologies for the merged cluster.
void	PreferAvailabilityStrategy.onPartitionMerge(AvailabilityStrategyContext context, Map<Address,CacheStatusResponse> statusResponseMap)
void	PreferConsistencyStrategy.onPartitionMerge(AvailabilityStrategyContext context, Map<Address,CacheStatusResponse> statusResponseMap)
void	AvailabilityStrategyContext.queueConflictResolution(CacheTopology conflictTopology, Set<Address> preferredNodes)	Initiates conflict resolution using the conflictTopology, which should have already been broadcast via invalid @link {@link this#updateTopologiesAfterMerge(CacheTopology, CacheTopology, AvailabilityMode) }
void	AvailabilityStrategyContext.queueRebalance(List<Address> newMembers)	Queue (or start) a rebalance.
boolean	AvailabilityStrategyContext.restartConflictResolution(List<Address> newMembers)	If CR is in progress, then this method cancels the current CR and starts a new CR phase with an updated topology based upon newMembers and the previously queued CR topology
void	AvailabilityStrategyContext.updateAvailabilityMode(List<Address> actualMembers, AvailabilityMode mode, boolean cancelRebalance)	Enter a new availability mode.
void	AvailabilityStrategyContext.updateCurrentTopology(List<Address> newMembers)	Use the configured ConsistentHashFactory to create a new CH with the given members, but do not start a rebalance.

Uses of Address in org.infinispan.reactive.publisher.impl

Constructor parameters in org.infinispan.reactive.publisher.impl with type arguments of type Address

Modifier	Constructor	Description
	InnerPublisherSubscriptionBuilder(ClusterPublisherManagerImpl<K,?>.org.infinispan.reactive.publisher.impl.ClusterPublisherManagerImpl.SubscriberHandler<I,R> parent, int batchSize, Supplier<Map.Entry<Address,IntSet>> supplier, Map<Address,Set<K>> excludedKeys, int topologyId)
	InnerPublisherSubscriptionBuilder(ClusterPublisherManagerImpl<K,?>.org.infinispan.reactive.publisher.impl.ClusterPublisherManagerImpl.SubscriberHandler<I,R> parent, int batchSize, Supplier<Map.Entry<Address,IntSet>> supplier, Map<Address,Set<K>> excludedKeys, int topologyId)

Uses of Address in org.infinispan.remoting.responses

Methods in org.infinispan.remoting.responses that return Address

Modifier and Type	Method	Description
Address[]	BiasRevocationResponse.getWaitList()

Methods in org.infinispan.remoting.responses with parameters of type Address

Modifier and Type	Method	Description
boolean	ClusteredGetResponseValidityFilter.isAcceptable(Response response, Address address)
boolean	IgnoreExtraResponsesValidityFilter.isAcceptable(Response response, Address address)

Constructors in org.infinispan.remoting.responses with parameters of type Address

Modifier	Constructor	Description
	BiasRevocationResponse(Object responseValue, Address[] waitFor)
	ClusteredGetResponseValidityFilter(Collection<Address> targets, Address self)
	IgnoreExtraResponsesValidityFilter(Collection<Address> targets, Address self, boolean removeSelf)

Constructor parameters in org.infinispan.remoting.responses with type arguments of type Address

Modifier	Constructor	Description
	ClusteredGetResponseValidityFilter(Collection<Address> targets, Address self)
	IgnoreExtraResponsesValidityFilter(Collection<Address> targets, Address self, boolean removeSelf)

Uses of Address in org.infinispan.remoting.rpc

Methods in org.infinispan.remoting.rpc that return Address

Modifier and Type	Method	Description
Address	RpcManager.getAddress()	Returns the address associated with this RpcManager or null if not part of the cluster.
Address	RpcManagerImpl.getAddress()

Methods in org.infinispan.remoting.rpc that return types with arguments of type Address

Modifier and Type	Method	Description
List<Address>	RpcManager.getMembers()	Returns members of a cluster scoped to the cache owning this RpcManager.
List<Address>	RpcManagerImpl.getMembers()
default CompletableFuture<Map<Address,Response>>	RpcManager.invokeRemotelyAsync(Collection<Address> recipients, ReplicableCommand rpc, RpcOptions options)	Deprecated, for removal: This API element is subject to removal in a future version. since 11.0, use RpcManager.sendToMany(Collection, ReplicableCommand, DeliverOrder) or RpcManager.invokeCommand(Collection, ReplicableCommand, ResponseCollector, RpcOptions) instead.
CompletableFuture<Map<Address,Response>>	RpcManagerImpl.invokeRemotelyAsync(Collection<Address> recipients, ReplicableCommand rpc, RpcOptions options)

Methods in org.infinispan.remoting.rpc with parameters of type Address

Modifier and Type	Method	Description
<T> CompletionStage<T>	RpcManager.invokeCommand(Address target, ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)	Invoke a command on a single node and pass the response to a ResponseCollector.
<T> CompletionStage<T>	RpcManagerImpl.invokeCommand(Address target, ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)
boolean	ResponseFilter.isAcceptable(Response response, Address sender)	Determines whether a response from a given sender should be added to the response list of the request
void	RpcManager.sendTo(Address destination, ReplicableCommand command, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder)	Asynchronously sends the ReplicableCommand to the destination using the specified DeliverOrder.
void	RpcManagerImpl.sendTo(Address destination, ReplicableCommand command, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder)

Method parameters in org.infinispan.remoting.rpc with type arguments of type Address

Modifier and Type	Method	Description
<T> CompletionStage<T>	RpcManager.invokeCommand(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)	Invoke a command on a collection of node and pass the responses to a ResponseCollector.
<T> CompletionStage<T>	RpcManagerImpl.invokeCommand(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)
<T> CompletionStage<T>	RpcManager.invokeCommands(Collection<Address> targets, Function<Address,ReplicableCommand> commandGenerator, ResponseCollector<T> collector, RpcOptions rpcOptions)	Invoke different commands on a collection of nodes and pass the responses to a ResponseCollector.
<T> CompletionStage<T>	RpcManager.invokeCommands(Collection<Address> targets, Function<Address,ReplicableCommand> commandGenerator, ResponseCollector<T> collector, RpcOptions rpcOptions)	Invoke different commands on a collection of nodes and pass the responses to a ResponseCollector.
<T> CompletionStage<T>	RpcManagerImpl.invokeCommands(Collection<Address> targets, Function<Address,ReplicableCommand> commandGenerator, ResponseCollector<T> collector, RpcOptions rpcOptions)
<T> CompletionStage<T>	RpcManagerImpl.invokeCommands(Collection<Address> targets, Function<Address,ReplicableCommand> commandGenerator, ResponseCollector<T> collector, RpcOptions rpcOptions)
<T> CompletionStage<T>	RpcManager.invokeCommandStaggered(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)	Invoke a command on a collection of nodes and pass the responses to a ResponseCollector.
<T> CompletionStage<T>	RpcManagerImpl.invokeCommandStaggered(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)
default CompletableFuture<Map<Address,Response>>	RpcManager.invokeRemotelyAsync(Collection<Address> recipients, ReplicableCommand rpc, RpcOptions options)	Deprecated, for removal: This API element is subject to removal in a future version. since 11.0, use RpcManager.sendToMany(Collection, ReplicableCommand, DeliverOrder) or RpcManager.invokeCommand(Collection, ReplicableCommand, ResponseCollector, RpcOptions) instead.
CompletableFuture<Map<Address,Response>>	RpcManagerImpl.invokeRemotelyAsync(Collection<Address> recipients, ReplicableCommand rpc, RpcOptions options)
void	RpcManager.sendToMany(Collection<Address> destinations, ReplicableCommand command, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder)	Asynchronously sends the ReplicableCommand to the set of destination using the specified DeliverOrder.
void	RpcManagerImpl.sendToMany(Collection<Address> destinations, ReplicableCommand command, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder)

Uses of Address in org.infinispan.remoting.transport

Subinterfaces of Address in org.infinispan.remoting.transport

Modifier and Type	Interface	Description
interface	TopologyAwareAddress	Wraps a TopologyUUID JGroups address

Classes in org.infinispan.remoting.transport that implement Address

Modifier and Type	Class	Description
class	LocalModeAddress	Represents the local node's address.
class	SiteAddress	Implementation Address that contains the site name.

Fields in org.infinispan.remoting.transport declared as Address

Modifier and Type	Field	Description
static final Address[]	Address.EMPTY_ARRAY
static final Address	LocalModeAddress.INSTANCE

Methods in org.infinispan.remoting.transport that return Address

Modifier and Type	Method	Description
Address	AbstractDelegatingTransport.getAddress()
Address	Transport.getAddress()	Retrieves the current cache instance's network address
Address	AbstractDelegatingTransport.getCoordinator()
Address	Transport.getCoordinator()

Methods in org.infinispan.remoting.transport that return types with arguments of type Address

Modifier and Type	Method	Description
List<Address>	AbstractDelegatingTransport.getMembers()
List<Address>	Transport.getMembers()	Returns a list of members in the current cluster view.
List<Address>	AbstractDelegatingTransport.getMembersPhysicalAddresses()
List<Address>	Transport.getMembersPhysicalAddresses()	Returns physical addresses of members in the current cluster view.
List<Address>	AbstractDelegatingTransport.getPhysicalAddresses()
List<Address>	Transport.getPhysicalAddresses()	Retrieves the current cache instance's physical network addresses.
Collection<Address>	AbstractDelegatingTransport.getRelayNodesAddress()
Collection<Address>	Transport.getRelayNodesAddress()
Map<Address,Response>	AbstractDelegatingTransport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter, boolean totalOrder, boolean anycast)	Deprecated, for removal: This API element is subject to removal in a future version.
Map<Address,Response>	AbstractDelegatingTransport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands, ResponseMode mode, long timeout, ResponseFilter responseFilter, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, boolean anycast)	Deprecated, for removal: This API element is subject to removal in a future version.
default Map<Address,Response>	Transport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter, boolean totalOrder, boolean anycast)	Deprecated, for removal: This API element is subject to removal in a future version. Use Transport.invokeRemotely(Map, ResponseMode, long, ResponseFilter, DeliverOrder, boolean) instead
default Map<Address,Response>	Transport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands, ResponseMode mode, long timeout, ResponseFilter responseFilter, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, boolean anycast)	Deprecated, for removal: This API element is subject to removal in a future version. Since 9.2, please use Transport.invokeRemotelyAsync(Collection, ReplicableCommand, ResponseMode, long, ResponseFilter, DeliverOrder, boolean) instead.
CompletableFuture<Map<Address,Response>>	AbstractDelegatingTransport.invokeRemotelyAsync(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, ResponseFilter responseFilter, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, boolean anycast)
CompletableFuture<Map<Address,Response>>	Transport.invokeRemotelyAsync(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, ResponseFilter responseFilter, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, boolean anycast)

Methods in org.infinispan.remoting.transport with parameters of type Address

Modifier and Type	Method	Description
protected abstract T	ValidResponseCollector.addException(Address sender, Exception exception)	Process an exception from a target.
T	ResponseCollector.addResponse(Address sender, Response response)	Called when a response is received, or when a target node becomes unavailable.
final T	ValidResponseCollector.addResponse(Address sender, Response response)
final T	ValidSingleResponseCollector.addResponse(Address sender, Response response)
protected abstract T	ValidResponseCollector.addTargetNotFound(Address sender)	Process a target leaving the cluster or stopping the cache.
protected abstract T	ValidResponseCollector.addValidResponse(Address sender, ValidResponse response)	Process a valid response from a target.
int	LocalModeAddress.compareTo(Address o)
int	SiteAddress.compareTo(Address o)
<T> CompletionStage<T>	AbstractDelegatingTransport.invokeCommand(Address target, ReplicableCommand command, ResponseCollector<T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit)
default <T> CompletionStage<T>	Transport.invokeCommand(Address target, ReplicableCommand command, ResponseCollector<T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit)	Invoke a command on a single node and pass the response to a ResponseCollector.
static SuspectException	ResponseCollectors.remoteNodeSuspected(Address sender)
void	AbstractDelegatingTransport.sendTo(Address destination, ReplicableCommand rpcCommand, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder)
void	Transport.sendTo(Address destination, ReplicableCommand rpcCommand, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder)	Asynchronously sends the ReplicableCommand to the destination using the specified DeliverOrder.
protected abstract T	ValidSingleResponseCollector.targetNotFound(Address sender)
protected T	ValidSingleResponseCollector.withException(Address sender, Exception exception)
protected abstract T	ValidSingleResponseCollector.withValidResponse(Address sender, ValidResponse response)
static CacheException	ResponseCollectors.wrapRemoteException(Address sender, Throwable exception)

Method parameters in org.infinispan.remoting.transport with type arguments of type Address

Modifier and Type	Method	Description
<T> CompletionStage<T>	AbstractDelegatingTransport.invokeCommand(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit)
default <T> CompletionStage<T>	Transport.invokeCommand(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit)	Invoke a command on a collection of node and pass the responses to a ResponseCollector.
default <T> CompletionStage<T>	Transport.invokeCommandOnAll(Collection<Address> requiredTargets, ReplicableCommand command, ResponseCollector<T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit)	Invoke a command on all the nodes in the cluster and pass the responses to a ResponseCollector.
<T> CompletionStage<T>	AbstractDelegatingTransport.invokeCommands(Collection<Address> targets, Function<Address,ReplicableCommand> commandGenerator, ResponseCollector<T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit timeUnit)
<T> CompletionStage<T>	AbstractDelegatingTransport.invokeCommands(Collection<Address> targets, Function<Address,ReplicableCommand> commandGenerator, ResponseCollector<T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit timeUnit)
default <T> CompletionStage<T>	Transport.invokeCommands(Collection<Address> targets, Function<Address,ReplicableCommand> commandGenerator, ResponseCollector<T> responseCollector, long timeout, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder)	Deprecated, for removal: This API element is subject to removal in a future version. Introduced in 9.1, but replaced in 9.2 with Transport.invokeCommands(Collection, Function, ResponseCollector, DeliverOrder, long, TimeUnit).
default <T> CompletionStage<T>	Transport.invokeCommands(Collection<Address> targets, Function<Address,ReplicableCommand> commandGenerator, ResponseCollector<T> responseCollector, long timeout, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder)	Deprecated, for removal: This API element is subject to removal in a future version. Introduced in 9.1, but replaced in 9.2 with Transport.invokeCommands(Collection, Function, ResponseCollector, DeliverOrder, long, TimeUnit).
default <T> CompletionStage<T>	Transport.invokeCommands(Collection<Address> targets, Function<Address,ReplicableCommand> commandGenerator, ResponseCollector<T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit timeUnit)	Invoke different commands on a collection of nodes and pass the responses to a ResponseCollector.
default <T> CompletionStage<T>	Transport.invokeCommands(Collection<Address> targets, Function<Address,ReplicableCommand> commandGenerator, ResponseCollector<T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit timeUnit)	Invoke different commands on a collection of nodes and pass the responses to a ResponseCollector.
<T> CompletionStage<T>	AbstractDelegatingTransport.invokeCommandStaggered(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit)
default <T> CompletionStage<T>	Transport.invokeCommandStaggered(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit)	Invoke a command on a collection of nodes and pass the responses to a ResponseCollector.
Map<Address,Response>	AbstractDelegatingTransport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter, boolean totalOrder, boolean anycast)	Deprecated, for removal: This API element is subject to removal in a future version.
Map<Address,Response>	AbstractDelegatingTransport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands, ResponseMode mode, long timeout, ResponseFilter responseFilter, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, boolean anycast)	Deprecated, for removal: This API element is subject to removal in a future version.
default Map<Address,Response>	Transport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter, boolean totalOrder, boolean anycast)	Deprecated, for removal: This API element is subject to removal in a future version. Use Transport.invokeRemotely(Map, ResponseMode, long, ResponseFilter, DeliverOrder, boolean) instead
default Map<Address,Response>	Transport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands, ResponseMode mode, long timeout, ResponseFilter responseFilter, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, boolean anycast)	Deprecated, for removal: This API element is subject to removal in a future version. Since 9.2, please use Transport.invokeRemotelyAsync(Collection, ReplicableCommand, ResponseMode, long, ResponseFilter, DeliverOrder, boolean) instead.
CompletableFuture<Map<Address,Response>>	AbstractDelegatingTransport.invokeRemotelyAsync(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, ResponseFilter responseFilter, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, boolean anycast)
CompletableFuture<Map<Address,Response>>	Transport.invokeRemotelyAsync(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, ResponseFilter responseFilter, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, boolean anycast)
void	AbstractDelegatingTransport.sendToMany(Collection<Address> destinations, ReplicableCommand rpcCommand, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder)
void	Transport.sendToMany(Collection<Address> destinations, ReplicableCommand rpcCommand, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder)	Asynchronously sends the ReplicableCommand to the set of destination using the specified DeliverOrder.

Uses of Address in org.infinispan.remoting.transport.impl

Fields in org.infinispan.remoting.transport.impl with type parameters of type Address

Modifier and Type	Field	Description
protected final HashMap<Address,Response>	MapResponseCollector.map

Methods in org.infinispan.remoting.transport.impl that return types with arguments of type Address

Modifier and Type	Method	Description
protected Map<Address,Response>	FilterMapResponseCollector.addException(Address sender, Exception exception)
protected Map<Address,Response>	MapResponseCollector.addException(Address sender, Exception exception)
Map<Address,Response>	PassthroughMapResponseCollector.addResponse(Address sender, Response response)
protected Map<Address,Response>	FilterMapResponseCollector.addTargetNotFound(Address sender)
protected Map<Address,Response>	FilterMapResponseCollector.addValidResponse(Address sender, ValidResponse response)
protected Map<Address,Response>	MapResponseCollector.addValidResponse(Address sender, ValidResponse response)
Map<Address,Response>	FilterMapResponseCollector.finish()
Map<Address,Response>	MapResponseCollector.finish()
Map<Address,Response>	PassthroughMapResponseCollector.finish()
protected Map<Address,Response>	SingletonMapResponseCollector.targetNotFound(Address sender)
protected Map<Address,Response>	SingletonMapResponseCollector.withValidResponse(Address sender, ValidResponse response)

Methods in org.infinispan.remoting.transport.impl with parameters of type Address

Modifier and Type	Method	Description
protected Map<Address,Response>	FilterMapResponseCollector.addException(Address sender, Exception exception)
protected Map<Address,Response>	MapResponseCollector.addException(Address sender, Exception exception)
protected Void	VoidResponseCollector.addException(Address sender, Exception exception)
Map<Address,Response>	PassthroughMapResponseCollector.addResponse(Address sender, Response response)
Response	PassthroughSingleResponseCollector.addResponse(Address sender, Response response)
void	RequestRepository.addResponse(long requestId, Address sender, Response response)
protected Map<Address,Response>	FilterMapResponseCollector.addTargetNotFound(Address sender)
protected Void	VoidResponseCollector.addTargetNotFound(Address sender)
protected Map<Address,Response>	FilterMapResponseCollector.addValidResponse(Address sender, ValidResponse response)
protected Map<Address,Response>	MapResponseCollector.addValidResponse(Address sender, ValidResponse response)
protected Void	VoidResponseCollector.addValidResponse(Address sender, ValidResponse response)
void	MultiTargetRequest.onResponse(Address sender, Response response)
void	Request.onResponse(Address sender, Response response)	Called when a response is received for this response.
void	SingleTargetRequest.onResponse(Address sender, Response response)
protected ValidResponse	SingleResponseCollector.targetNotFound(Address sender)
protected Map<Address,Response>	SingletonMapResponseCollector.targetNotFound(Address sender)
protected ValidResponse	SingleResponseCollector.withValidResponse(Address sender, ValidResponse response)
protected Map<Address,Response>	SingletonMapResponseCollector.withValidResponse(Address sender, ValidResponse response)

Method parameters in org.infinispan.remoting.transport.impl with type arguments of type Address

Modifier and Type	Method	Description
boolean	MultiTargetRequest.onNewView(Set<Address> members)
boolean	Request.onNewView(Set<Address> members)	Called when the node received a new cluster view.
boolean	SingleTargetRequest.onNewView(Set<Address> members)

Constructors in org.infinispan.remoting.transport.impl with parameters of type Address

Modifier	Constructor	Description
	MultiTargetRequest(ResponseCollector<T> responseCollector, long requestId, RequestRepository repository, Collection<Address> targets, Address excluded, JGroupsMetricsManager metricsCollector)

Constructor parameters in org.infinispan.remoting.transport.impl with type arguments of type Address

Modifier	Constructor	Description
	MultiTargetRequest(ResponseCollector<T> responseCollector, long requestId, RequestRepository repository, Collection<Address> targets, Address excluded, JGroupsMetricsManager metricsCollector)

Uses of Address in org.infinispan.remoting.transport.jgroups

Classes in org.infinispan.remoting.transport.jgroups that implement Address

Modifier and Type	Class	Description
class	JGroupsAddress	An encapsulation of a JGroups Address
class	JGroupsTopologyAwareAddress	An encapsulation of a JGroups ExtendedUUID with a site id, a rack id, and a machine id.

Fields in org.infinispan.remoting.transport.jgroups declared as Address

Modifier and Type	Field	Description
protected Address	JGroupsTransport.address
protected Address	JGroupsTransport.physicalAddress

Methods in org.infinispan.remoting.transport.jgroups that return Address

Modifier and Type	Method	Description
Address	RequestTracker.destination()
static Address	JGroupsAddressCache.fromJGroupsAddress(org.jgroups.Address jgroupsAddress)
Address	JGroupsTransport.getAddress()
Address	ClusterView.getCoordinator()
Address	JGroupsTransport.getCoordinator()
Address	SuspectException.getSuspect()

Methods in org.infinispan.remoting.transport.jgroups that return types with arguments of type Address

Modifier and Type	Method	Description
List<Address>	ClusterView.getMembers()
List<Address>	JGroupsTransport.getMembers()
List<Address>	JGroupsTransport.getMembersPhysicalAddresses()
Set<Address>	ClusterView.getMembersSet()
List<Address>	JGroupsTransport.getPhysicalAddresses()
Collection<Address>	JGroupsTransport.getRelayNodesAddress()
Map<Address,Response>	JGroupsTransport.invokeRemotely(Map<Address,ReplicableCommand> commands, ResponseMode mode, long timeout, ResponseFilter responseFilter, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, boolean anycast)	Deprecated, for removal: This API element is subject to removal in a future version.
CompletableFuture<Map<Address,Response>>	JGroupsTransport.invokeRemotelyAsync(Collection<Address> recipients, ReplicableCommand command, ResponseMode mode, long timeout, ResponseFilter responseFilter, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, boolean anycast)

Methods in org.infinispan.remoting.transport.jgroups with parameters of type Address

Modifier and Type	Method	Description
int	JGroupsAddress.compareTo(Address o)
<T> CompletionStage<T>	JGroupsTransport.invokeCommand(Address target, ReplicableCommand command, ResponseCollector<T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit)
void	SingleSiteRequest.onResponse(Address sender, Response response)
void	StaggeredRequest.onResponse(Address sender, Response response)
void	JGroupsMetricsManager.recordMessageSent(Address destination, int bytesSent, boolean async)	Records a message sent to a destination.
void	JGroupsMetricsManagerImpl.recordMessageSent(Address destination, int bytesSent, boolean async)
void	NoOpJGroupsMetricManager.recordMessageSent(Address destination, int bytesSent, boolean async)
void	JGroupsTransport.sendTo(Address destination, ReplicableCommand command, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder)
RequestTracker	JGroupsMetricsManager.trackRequest(Address destination)	Track the latency for a synchronous request.
RequestTracker	JGroupsMetricsManagerImpl.trackRequest(Address destination)
RequestTracker	NoOpJGroupsMetricManager.trackRequest(Address destination)

Method parameters in org.infinispan.remoting.transport.jgroups with type arguments of type Address

Modifier and Type	Method	Description
<T> CompletionStage<T>	JGroupsTransport.invokeCommand(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit)
<T> CompletionStage<T>	JGroupsTransport.invokeCommandOnAll(Collection<Address> requiredTargets, ReplicableCommand command, ResponseCollector<T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit)
<T> CompletionStage<T>	JGroupsTransport.invokeCommands(Collection<Address> targets, Function<Address,ReplicableCommand> commandGenerator, ResponseCollector<T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit timeUnit)
<T> CompletionStage<T>	JGroupsTransport.invokeCommands(Collection<Address> targets, Function<Address,ReplicableCommand> commandGenerator, ResponseCollector<T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit timeUnit)
<T> CompletionStage<T>	JGroupsTransport.invokeCommandStaggered(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit)
Map<Address,Response>	JGroupsTransport.invokeRemotely(Map<Address,ReplicableCommand> commands, ResponseMode mode, long timeout, ResponseFilter responseFilter, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, boolean anycast)	Deprecated, for removal: This API element is subject to removal in a future version.
CompletableFuture<Map<Address,Response>>	JGroupsTransport.invokeRemotelyAsync(Collection<Address> recipients, ReplicableCommand command, ResponseMode mode, long timeout, ResponseFilter responseFilter, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, boolean anycast)
boolean	SingleSiteRequest.onNewView(Set<Address> members)
void	JGroupsTransport.sendToMany(Collection<Address> targets, ReplicableCommand command, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder)

Constructors in org.infinispan.remoting.transport.jgroups with parameters of type Address

Modifier	Constructor	Description
	SuspectException(String msg, Address suspect)
	SuspectException(String msg, Address suspect, Throwable cause)

Uses of Address in org.infinispan.server.hotrod

Methods in org.infinispan.server.hotrod that return types with arguments of type Address

Modifier and Type	Method	Description
Cache<Address,ServerAddress>	HotRodServer.getAddressCache()

Uses of Address in org.infinispan.server.hotrod.tx

Methods in org.infinispan.server.hotrod.tx with parameters of type Address

Modifier and Type	Method	Description
final boolean	PrepareCoordinator.isAlive(Address address)

Method parameters in org.infinispan.server.hotrod.tx with type arguments of type Address

Modifier and Type	Method	Description
boolean	ServerTransactionOriginatorChecker.isOriginatorMissing(GlobalTransaction gtx, Collection<Address> liveMembers)

Uses of Address in org.infinispan.server.hotrod.tx.table

Classes in org.infinispan.server.hotrod.tx.table that implement Address

Modifier and Type	Class	Description
class	ClientAddress	A Address implementation for a client transaction.

Methods in org.infinispan.server.hotrod.tx.table that return Address

Modifier and Type	Method	Description
Address	TxState.getOriginator()

Methods in org.infinispan.server.hotrod.tx.table with parameters of type Address

Modifier and Type	Method	Description
int	ClientAddress.compareTo(Address o)

Constructors in org.infinispan.server.hotrod.tx.table with parameters of type Address

Modifier	Constructor	Description
	ClientAddress(Address localAddress)
	PerCacheTxTable(Address address)

Uses of Address in org.infinispan.stream.impl

Fields in org.infinispan.stream.impl declared as Address

Modifier and Type	Field	Description
protected final Address	AbstractCacheStream.localAddress

Constructors in org.infinispan.stream.impl with parameters of type Address

Modifier	Constructor	Description
protected	AbstractCacheStream(Address localAddress, boolean parallel, InvocationContext ctx, long explicitFlags, int distributedBatchSize, Executor executor, ComponentRegistry registry, Function<? super Original,?> toKeyFunction, ClusterPublisherManager<?,?> clusterPublisherManager)
	DistributedCacheStream(Address localAddress, boolean parallel, InvocationContext ctx, long explicitFlags, int distributedBatchSize, Executor executor, ComponentRegistry registry, Function<? super Original,?> toKeyFunction, ClusterPublisherManager<?,?> clusterPublisherManager)	Standard constructor requiring all pertinent information to properly utilize a distributed cache stream

Uses of Address in org.infinispan.topology

Classes in org.infinispan.topology that implement Address

Modifier and Type	Class	Description
class	PersistentUUID	PersistentUUID.

Methods in org.infinispan.topology that return Address

Modifier and Type	Method	Description
Address	PersistentUUIDManager.getAddress(PersistentUUID persistentUUID)	Retrieves the Address of a node given its PersistentUUID
Address	PersistentUUIDManagerImpl.getAddress(PersistentUUID persistentUUID)

Methods in org.infinispan.topology that return types with arguments of type Address

Modifier and Type	Method	Description
UnaryOperator<Address>	PersistentUUIDManager.addressToPersistentUUID()	Provides a remapping operator which translates addresses to persistentuuids
UnaryOperator<Address>	PersistentUUIDManagerImpl.addressToPersistentUUID()
List<Address>	ClusterTopologyManager.currentJoiners(String cacheName)	Returns the list of nodes that joined the cache with the given cacheName if the current node is the coordinator.
List<Address>	ClusterTopologyManagerImpl.currentJoiners(String cacheName)
List<Address>	CacheTopology.getActualMembers()
Map<Address,Float>	ClusterCacheStatus.getCapacityFactors()
List<Address>	ClusterCacheStatus.getExpectedMembers()
List<Address>	CacheTopology.getMembers()
List<Address>	CacheStatusResponse.joinedMembers()
UnaryOperator<Address>	PersistentUUIDManager.persistentUUIDToAddress()	Provides a remapping operator which translates persistentuuids to addresses
UnaryOperator<Address>	PersistentUUIDManagerImpl.persistentUUIDToAddress()

Methods in org.infinispan.topology with parameters of type Address

Modifier and Type	Method	Description
void	PersistentUUIDManager.addPersistentAddressMapping(Address address, PersistentUUID persistentUUID)	Adds a mapping between an Address and a PersistentUUID
void	PersistentUUIDManagerImpl.addPersistentAddressMapping(Address address, PersistentUUID persistentUUID)
int	PersistentUUID.compareTo(Address o)
void	ClusterCacheStatus.confirmRebalancePhase(Address member, int receivedTopologyId)
CacheStatusResponse	ClusterCacheStatus.doJoin(Address joiner, CacheJoinInfo joinInfo)
CompletionStage<Void>	ClusterCacheStatus.doLeave(Address leaver)
PersistentUUID	PersistentUUIDManager.getPersistentUuid(Address address)	Retrieves the PersistentUUID of a node given its Address
PersistentUUID	PersistentUUIDManagerImpl.getPersistentUuid(Address address)
CompletionStage<CacheStatusResponse>	ClusterTopologyManager.handleJoin(String cacheName, Address joiner, CacheJoinInfo joinInfo, int viewId)	Signals that a new member is joining the cache.
CompletionStage<CacheStatusResponse>	ClusterTopologyManagerImpl.handleJoin(String cacheName, Address joiner, CacheJoinInfo joinInfo, int joinerViewId)
CompletionStage<Void>	ClusterTopologyManager.handleLeave(String cacheName, Address leaver, int viewId)	Signals that a member is leaving the cache.
CompletionStage<Void>	ClusterTopologyManagerImpl.handleLeave(String cacheName, Address leaver, int viewId)
CompletionStage<Void>	LocalTopologyManager.handleRebalance(String cacheName, CacheTopology cacheTopology, int viewId, Address sender)	Performs the state transfer.
CompletionStage<Void>	LocalTopologyManagerImpl.handleRebalance(String cacheName, CacheTopology cacheTopology, int viewId, Address sender)
CompletionStage<Void>	ClusterTopologyManager.handleRebalancePhaseConfirm(String cacheName, Address node, int topologyId, Throwable throwable, int viewId)	Marks the rebalance as complete on the sender.
CompletionStage<Void>	ClusterTopologyManagerImpl.handleRebalancePhaseConfirm(String cacheName, Address node, int topologyId, Throwable throwable, int viewId)
CompletionStage<Void>	LocalTopologyManager.handleStableTopologyUpdate(String cacheName, CacheTopology cacheTopology, Address sender, int viewId)	Update the stable cache topology.
CompletionStage<Void>	LocalTopologyManagerImpl.handleStableTopologyUpdate(String cacheName, CacheTopology newStableTopology, Address sender, int viewId)
CompletionStage<Void>	LocalTopologyManager.handleTopologyUpdate(String cacheName, CacheTopology cacheTopology, AvailabilityMode availabilityMode, int viewId, Address sender)	Updates the current and/or pending consistent hash, without transferring any state.
CompletionStage<Void>	LocalTopologyManagerImpl.handleTopologyUpdate(String cacheName, CacheTopology cacheTopology, AvailabilityMode availabilityMode, int viewId, Address sender)
void	PersistentUUIDManager.removePersistentAddressMapping(Address address)	Removes any address mapping for the specified Address
void	PersistentUUIDManagerImpl.removePersistentAddressMapping(Address address)

Method parameters in org.infinispan.topology with type arguments of type Address

Modifier and Type	Method	Description
ConsistentHash	ClusterCacheStatus.calculateConflictHash(ConsistentHash preferredHash, Set<ConsistentHash> distinctHashes, List<Address> actualMembers)
static boolean	ClusterTopologyManagerImpl.distLostDataCheck(ConsistentHash stableCH, List<Address> newMembers)
void	ClusterCacheStatus.doMergePartitions(Map<Address,CacheStatusResponse> statusResponses)
void	ClusterCacheStatus.manuallyUpdateAvailabilityMode(List<Address> actualMembers, AvailabilityMode mode, boolean cancelRebalance)
List<PersistentUUID>	PersistentUUIDManager.mapAddresses(List<Address> addresses)	Returns a list of PersistentUUIDs for the supplied Addresses
List<PersistentUUID>	PersistentUUIDManagerImpl.mapAddresses(List<Address> addresses)
void	ClusterCacheStatus.queueConflictResolution(CacheTopology conflictTopology, Set<Address> preferredNodes)
void	ClusterCacheStatus.queueRebalance(List<Address> newMembers)
boolean	ClusterCacheStatus.restartConflictResolution(List<Address> members)
void	ClusterCacheStatus.updateAvailabilityMode(List<Address> actualMembers, AvailabilityMode newAvailabilityMode, boolean cancelRebalance)
void	ClusterCacheStatus.updateCurrentTopology(List<Address> newMembers)

Constructor parameters in org.infinispan.topology with type arguments of type Address

Modifier	Constructor	Description
	CacheStatusResponse(CacheJoinInfo cacheJoinInfo, CacheTopology cacheTopology, CacheTopology stableTopology, AvailabilityMode availabilityMode, List<Address> current)
	CacheTopology(int topologyId, int rebalanceId, boolean restoredTopology, ConsistentHash currentCH, ConsistentHash pendingCH, ConsistentHash unionCH, CacheTopology.Phase phase, List<Address> actualMembers, List<PersistentUUID> persistentUUIDs)
	CacheTopology(int topologyId, int rebalanceId, boolean restoredTopology, ConsistentHash currentCH, ConsistentHash pendingCH, CacheTopology.Phase phase, List<Address> actualMembers, List<PersistentUUID> persistentUUIDs)
	CacheTopology(int topologyId, int rebalanceId, ConsistentHash currentCH, ConsistentHash pendingCH, ConsistentHash unionCH, CacheTopology.Phase phase, List<Address> actualMembers, List<PersistentUUID> persistentUUIDs)
	CacheTopology(int topologyId, int rebalanceId, ConsistentHash currentCH, ConsistentHash pendingCH, CacheTopology.Phase phase, List<Address> actualMembers, List<PersistentUUID> persistentUUIDs)

Uses of Address in org.infinispan.transaction.impl

Methods in org.infinispan.transaction.impl that return types with arguments of type Address

Modifier and Type	Method	Description
Collection<Address>	LocalTransaction.getCommitNodes(Collection<Address> recipients, CacheTopology cacheTopology)	Calculates the list of nodes to which a commit/rollback needs to be sent based on the nodes to which prepare was sent.
Collection<Address>	LocalTransaction.getRemoteLocksAcquired()

Method parameters in org.infinispan.transaction.impl with type arguments of type Address

Modifier and Type	Method	Description
void	TransactionTable.cleanupLeaverTransactions(List<Address> members)
Collection<Address>	LocalTransaction.getCommitNodes(Collection<Address> recipients, CacheTopology cacheTopology)	Calculates the list of nodes to which a commit/rollback needs to be sent based on the nodes to which prepare was sent.
boolean	ClusteredTransactionOriginatorChecker.isOriginatorMissing(GlobalTransaction gtx, Collection<Address> liveMembers)
boolean	TransactionOriginatorChecker.isOriginatorMissing(GlobalTransaction gtx, Collection<Address> liveMembers)
void	LocalTransaction.locksAcquired(Collection<Address> nodes)

Uses of Address in org.infinispan.transaction.xa

Methods in org.infinispan.transaction.xa that return Address

Modifier and Type	Method	Description
Address	GlobalTransaction.getAddress()

Methods in org.infinispan.transaction.xa with parameters of type Address

Modifier and Type	Method	Description
GlobalTransaction	TransactionFactory.newGlobalTransaction(Address addr, boolean remote)
abstract GlobalTransaction	TransactionFactory.TxFactoryEnum.newGlobalTransaction(Address addr, boolean remote, VersionGenerator clusterIdGenerator, boolean clustered)
void	GlobalTransaction.setAddress(Address address)

Constructors in org.infinispan.transaction.xa with parameters of type Address

Modifier	Constructor	Description
	GlobalTransaction(Address addr, boolean remote)

Uses of Address in org.infinispan.transaction.xa.recovery

Methods in org.infinispan.transaction.xa.recovery that return types with arguments of type Address

Modifier and Type	Method	Description
Set<Address>	InDoubtTxInfo.getOwners()

Methods in org.infinispan.transaction.xa.recovery with parameters of type Address

Modifier and Type	Method	Description
void	InDoubtTxInfo.addOwner(Address owner)	Adds owner as a node where this transaction information is maintained.
String	RecoveryManager.forceTransactionCompletionFromCluster(XidImpl xid, Address where, boolean commit)	This method invokes RecoveryManager.forceTransactionCompletion(XidImpl, boolean) on the specified node.
String	RecoveryManagerImpl.forceTransactionCompletionFromCluster(XidImpl xid, Address where, boolean commit)

Method parameters in org.infinispan.transaction.xa.recovery with type arguments of type Address

Modifier and Type	Method	Description
void	RecoveryAwareTransactionTable.cleanupLeaverTransactions(List<Address> members)	First moves the prepared transactions originated on the leavers into the recovery cache and then cleans up the transactions that are not yet prepared.
void	RecoveryAwareRemoteTransaction.computeOrphan(Collection<Address> currentMembers)	Check's if this transaction's originator is no longer part of the cluster (orphan transaction) and updates RecoveryAwareRemoteTransaction.isOrphan().
CompletionStage<Void>	RecoveryManager.removeRecoveryInformation(Collection<Address> where, XidImpl xid, GlobalTransaction gtx, boolean fromCluster)	Removes from the specified nodes (or all nodes if the value of 'where' is null) the recovery information associated with these Xids.
CompletionStage<Void>	RecoveryManagerImpl.removeRecoveryInformation(Collection<Address> lockOwners, XidImpl xid, GlobalTransaction gtx, boolean fromCluster)
CompletionStage<Void>	RecoveryManager.removeRecoveryInformationFromCluster(Collection<Address> where, long internalId)	Same as RecoveryManager.removeRecoveryInformation(Collection, XidImpl, GlobalTransaction, boolean) but the transaction is identified by its internal id, and not by its xid.
CompletionStage<Void>	RecoveryManagerImpl.removeRecoveryInformationFromCluster(Collection<Address> where, long internalId)

Uses of Address in org.infinispan.util.concurrent

Methods in org.infinispan.util.concurrent with parameters of type Address

Modifier and Type	Method	Description
void	CommandAckCollector.backupAck(long id, Address from, int segment, int topologyId)	Acknowledges a PutMapCommand completion in the backup owner.

Method parameters in org.infinispan.util.concurrent with type arguments of type Address

Modifier and Type	Method	Description
<T> org.infinispan.interceptors.distribution.Collector<T>	CommandAckCollector.create(long id, Collection<Address> backupOwners, int topologyId)	Creates a collector for a single key write operation.
<T> org.infinispan.interceptors.distribution.Collector<T>	CommandAckCollector.createSegmentBasedCollector(long id, Map<Address,Collection<Integer>> backups, int topologyId)	Creates a collector for PutMapCommand.
void	CommandAckCollector.onMembersChange(Collection<Address> members)	Notifies a change in member list.

Uses of Address in org.infinispan.xsite.irac

Methods in org.infinispan.xsite.irac with parameters of type Address

Modifier and Type	Method	Description
void	DefaultIracManager.requestState(Address requestor, IntSet segments)
void	IracManager.requestState(Address requestor, IntSet segments)	Requests the state stored in this instance for the given segments.
void	NoOpIracManager.requestState(Address requestor, IntSet segments)

Uses of Address in org.infinispan.xsite.response

Methods in org.infinispan.xsite.response with parameters of type Address

Modifier and Type	Method	Description
final AutoStateTransferResponse	AutoStateTransferResponseCollector.addResponse(Address sender, Response response)

Uses of Address in org.infinispan.xsite.statetransfer

Methods in org.infinispan.xsite.statetransfer with parameters of type Address

Modifier and Type	Method	Description
boolean	RemoteSiteStatus.confirmStateTransfer(Address node, boolean statusOk)
boolean	XSiteStateTransferCollector.confirmStateTransfer(Address node, boolean statusOk)
XSiteStatePushTask	BaseXSiteStateProviderState.createPushTask(Address originator, XSiteStateProvider provider)
XSiteStatePushTask	XSiteStateProviderState.createPushTask(Address originator, XSiteStateProvider provider)	Creates a new XSiteStatePushTask to do state transfer to remove site.
void	NoOpXSiteStateTransferManager.notifyStatePushFinished(String siteName, Address node, boolean statusOk)
void	XSiteStateTransferManager.notifyStatePushFinished(String siteName, Address node, boolean statusOk)	It receives the notifications from local site when some node finishes pushing the state to the remote site.
void	XSiteStateTransferManagerImpl.notifyStatePushFinished(String siteName, Address node, boolean statusOk)
void	NoOpXSiteStateProvider.notifyStateTransferEnd(String siteName, Address origin, boolean statusOk)
void	XSiteStateProvider.notifyStateTransferEnd(String siteName, Address origin, boolean statusOk)	Notifies XSiteStatePushTask has completed the send.
void	XSiteStateProviderImpl.notifyStateTransferEnd(String siteName, Address origin, boolean statusOk)
void	NoOpXSiteStateProvider.startStateTransfer(String siteName, Address requestor, int minTopologyId)
void	XSiteStateProvider.startStateTransfer(String siteName, Address requestor, int minTopologyId)	It notifies this node to start sending state to the remote site.
void	XSiteStateProviderImpl.startStateTransfer(String siteName, Address origin, int minTopologyId)

Method parameters in org.infinispan.xsite.statetransfer with type arguments of type Address

Modifier and Type	Method	Description
Collection<String>	NoOpXSiteStateProvider.getSitesMissingCoordinator(Collection<Address> currentMembers)
Collection<String>	XSiteStateProvider.getSitesMissingCoordinator(Collection<Address> currentMembers)
Collection<String>	XSiteStateProviderImpl.getSitesMissingCoordinator(Collection<Address> currentMembers)
boolean	BaseXSiteStateProviderState.isOriginatorMissing(Collection<Address> members)
boolean	XSiteStateProviderState.isOriginatorMissing(Collection<Address> members)	Returns
boolean	RemoteSiteStatus.restartStateTransfer(Collection<Address> newMembers)
boolean	RemoteSiteStatus.startStateTransfer(Collection<Address> members)
boolean	XSiteStateTransferCollector.updateMembers(Collection<Address> members)

Constructor parameters in org.infinispan.xsite.statetransfer with type arguments of type Address

Modifier	Constructor	Description
	XSiteStateTransferCollector(Collection<Address> confirmationPending)

Uses of Address in org.infinispan.xsite.status

Methods in org.infinispan.xsite.status with parameters of type Address

Modifier and Type	Method	Description
void	CacheSiteStatusBuilder.addMember(Address address, boolean online)	Adds a member with an online/offline connection to the server based on the online parameter.

Method parameters in org.infinispan.xsite.status with type arguments of type Address

Modifier and Type	Method	Description
protected SiteStatus	CacheSiteStatusBuilder.createMixedStatus(List<Address> onlineElements, List<Address> offlineElements)

Constructor parameters in org.infinispan.xsite.status with type arguments of type Address

Modifier	Constructor	Description
	CacheMixedSiteStatus(List<Address> onlineMembers, List<Address> offlineMembers)