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.conflict.impl	This package contains implementations of the conflict resolution API.
org.infinispan.container.entries	Entries which are stored in data containers.
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.distexec	Distributed Executor APIs (deprecated)
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.group.impl
org.infinispan.distribution.impl
org.infinispan.distribution.topologyaware
org.infinispan.interceptors.distribution	Interceptors dealing with command replication in distributed/replicated mode.
org.infinispan.interceptors.impl	Basic interceptors
org.infinispan.interceptors.locking	Interceptors dealing with locking.
org.infinispan.interceptors.totalorder	Interceptors dealing with total order.
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	Cache-specific listener events
org.infinispan.notifications.cachelistener.event.impl
org.infinispan.notifications.cachemanagerlistener	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.query.affinity	This package contains the implementation of the AffinityIndexManager, that maintains an index divided into shards with storage using the Infinispan Lucene directory.
org.infinispan.query.clustered
org.infinispan.query.logging
org.infinispan.remoting	Remote communication between cache instances.
org.infinispan.remoting.inboundhandler	Handling of inbound commands on remote nodes.
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.scattered	SCATTERED CACHE DESIGN
org.infinispan.scattered.impl
org.infinispan.security.actions
org.infinispan.server.hotrod
org.infinispan.server.hotrod.tx
org.infinispan.server.hotrod.tx.table
org.infinispan.statetransfer	Transfer of state to new caches in a cluster.
org.infinispan.stats.wrappers
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	General utilities that are not specific to Infinispan, including string parsing helpers, reflection tools and collections and containers designed to supplement the JDK-provided containers.
org.infinispan.util.concurrent	Thread-safe containers and other concurrency-related utilities, designed to supplement JDK concurrency utilities and containers.
org.infinispan.util.logging	Infinispan's logging abstractions that delegate to either JDK or Log4J logging engines.
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.

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

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

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

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
<T> org.infinispan.commands.read.DistributedExecuteCommand<T>	CommandsFactory.buildDistributedExecuteCommand(Callable<T> callable, Address sender, Collection keys)	Builds a DistributedExecuteCommand used for migration and execution of distributed Callables and Runnables.
<T> org.infinispan.commands.read.DistributedExecuteCommand<T>	CommandsFactoryImpl.buildDistributedExecuteCommand(Callable<T> callable, Address sender, Collection keys)
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)
org.infinispan.commands.remote.RevokeBiasCommand	CommandsFactory.buildRevokeBiasCommand(Address ackTarget, long id, int topologyId, Collection<Object> keys)
org.infinispan.commands.remote.RevokeBiasCommand	CommandsFactoryImpl.buildRevokeBiasCommand(Address ackTarget, long id, int topologyId, Collection<Object> keys)
StateRequestCommand	CommandsFactory.buildStateRequestCommand(StateRequestCommand.Type subtype, Address sender, int topologyId, org.infinispan.commons.util.IntSet segments)	Builds a StateRequestCommand used for requesting transactions and locks and for starting or canceling transfer of cache entries.
StateRequestCommand	CommandsFactoryImpl.buildStateRequestCommand(StateRequestCommand.Type subtype, Address sender, int topologyId, org.infinispan.commons.util.IntSet segments)
StateResponseCommand	CommandsFactory.buildStateResponseCommand(Address sender, int viewId, Collection<StateChunk> stateChunks, boolean applyState, boolean pushTransfer)	Builds a StateResponseCommand used for pushing cache entries to another node in response to a StateRequestCommand.
StateResponseCommand	CommandsFactoryImpl.buildStateResponseCommand(Address sender, int topologyId, Collection<StateChunk> stateChunks, boolean applyState, boolean pushTransfer)
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.conflict.impl

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

Modifier and Type	Method	Description
CompletableFuture<List<Map<Address,CacheEntry<K,V>>>>	StateReceiver.getAllReplicasForSegment(int segmentId, LocalizedCacheTopology topology, long timeout)	Return all replicas of a cache entry for a given segment.
CompletableFuture<List<Map<Address,CacheEntry<K,V>>>>	StateReceiverImpl.getAllReplicasForSegment(int segmentId, LocalizedCacheTopology topology, long timeout)
Map<Address,InternalCacheValue<V>>	DefaultConflictManager.getAllVersions(K key)
Stream<Map<Address,CacheEntry<K,V>>>	DefaultConflictManager.getConflicts()

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

Modifier and Type	Method	Description
void	StateReceiver.receiveState(Address sender, int topologyId, Collection<StateChunk> stateChunks)
void	StateReceiverImpl.receiveState(Address sender, int topologyId, Collection<StateChunk> stateChunks)

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

Modifier and Type	Method	Description
CompletableFuture<Void>	DefaultConflictManager.resolveConflicts(CacheTopology topology, Set<Address> preferredNodes)
CompletableFuture<Void>	InternalConflictManager.resolveConflicts(CacheTopology cacheTopology, Set<Address> preferredNodes)

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

Constructor	Description
RemoteMetadata(Address address, EntryVersion version)

Uses of Address in org.infinispan.context

Methods in org.infinispan.context that return Address

Modifier and Type	Method	Description
Address	InvocationContext.getOrigin()
Address	SingleKeyNonTxInvocationContext.getOrigin()	Deprecated.

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.
NonTxInvocationContext	NonTransactionalInvocationContextFactory.createRemoteInvocationContext(Address origin)	Deprecated.
NonTxInvocationContext	TransactionalInvocationContextFactory.createRemoteInvocationContext(Address origin)	Deprecated.
InvocationContext	AbstractInvocationContextFactory.createRemoteInvocationContextForCommand(VisitableCommand cacheCommand, Address origin)	Deprecated.
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.
RemoteTxInvocationContext	NonTransactionalInvocationContextFactory.createRemoteTxInvocationContext(RemoteTransaction tx, Address origin)	Deprecated.
RemoteTxInvocationContext	TransactionalInvocationContextFactory.createRemoteTxInvocationContext(RemoteTransaction tx, Address origin)	Deprecated.
protected NonTxInvocationContext	TransactionalInvocationContextFactory.newNonTxInvocationContext(Address origin)	Deprecated.

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

Constructor	Description
SingleKeyNonTxInvocationContext(Address origin)	Deprecated.

Uses of Address in org.infinispan.context.impl

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

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

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

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

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

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

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

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

Uses of Address in org.infinispan.distexec

Methods in org.infinispan.distexec that return Address

Modifier and Type	Method	Description
Address	FailoverContext.executionFailureLocation()	Returns an Address of the node where the task failed
Address	DistributedTaskFailoverPolicy.failover(FailoverContext context)	As parts of distributively executed task can fail due to the task itself throwing an exception or it can be an Infinispan system caused failure (e.g node failed or left cluster during task execution etc).
protected Address	DefaultExecutorService.selectExecutionNode(List<Address> candidates)	Deprecated.
protected <T> Address	DefaultExecutorService.selectExecutionNode(DistributedTask<T> task)	Deprecated.

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

Modifier and Type	Method	Description
protected <T> List<Address>	DefaultExecutorService.executionCandidates(DistributedTask<T> task)	Deprecated.
List<Address>	FailoverContext.executionCandidates()	Returns a list of candidates for possible repeated execution governed by installed DistributedTaskFailoverPolicy
protected List<Address>	DefaultExecutorService.getMembers()	Deprecated.
protected <K> Map<Address,List<K>>	DefaultExecutorService.keysToExecutionNodes(DistributedTaskExecutionPolicy policy, K... input)	Deprecated.
protected List<Address>	DefaultExecutorService.randomClusterMembers(List<Address> members, int numNeeded)	Deprecated.

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

Modifier and Type	Method	Description
protected <T,K> org.infinispan.distexec.DefaultExecutorService.DistributedTaskPart<T>	DefaultExecutorService.createDistributedTaskPart(DistributedTask<T> task, org.infinispan.commands.read.DistributedExecuteCommand<T> c, List<K> inputKeys, Address target, int failoverCount)	Deprecated.
protected <T,K> org.infinispan.distexec.DefaultExecutorService.DistributedTaskPart<T>	DefaultExecutorService.createDistributedTaskPart(DistributedTask<T> task, org.infinispan.commands.read.DistributedExecuteCommand<T> c, Address target, int failoverCount)	Deprecated.
<T> CompletableFuture<T>	DefaultExecutorService.submit(Address target, Callable<T> task)	Deprecated.
<T> CompletableFuture<T>	DefaultExecutorService.submit(Address target, DistributedTask<T> task)	Deprecated.
<K> CompletableFuture<V>	DistributedExecutionCompletionService.submit(Address target, Callable<V> task)
<T> CompletableFuture<T>	DistributedExecutorService.submit(Address target, Callable<T> task)	Deprecated. Submits the given Callable task for execution on the specified target Infinispan node.
<T> CompletableFuture<T>	DistributedExecutorService.submit(Address target, DistributedTask<T> task)	Deprecated. Submits the given DistributedTask for execution on the specified target Infinispan node.

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

Modifier and Type	Method	Description
protected List<Address>	DefaultExecutorService.randomClusterMembers(List<Address> members, int numNeeded)	Deprecated.
protected Address	DefaultExecutorService.selectExecutionNode(List<Address> candidates)	Deprecated.

Uses of Address in org.infinispan.distribution

Methods in org.infinispan.distribution that return Address

Modifier and Type	Method	Description
Address	LocalizedCacheTopology.getLocalAddress()
Address	DistributionManager.getPrimaryLocation(Object key)	Deprecated. Since 9.0, please use getCacheTopology().getDistributionInfo(key) instead.
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>	DistributionManager.locate(Object key)	Deprecated. Since 9.0, please use getCacheTopology().getDistributionInfo(key) instead.
Set<Address>	DistributionManager.locateAll(Collection<Object> keys)	Deprecated. Since 9.0, no direct replacement.
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

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

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
default Address	ConsistentHash.locatePrimaryOwner(Object key)	Deprecated. Since 9.0, please use LocalizedCacheTopology.getDistribution(Object) instead.
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.
default Set<Address>	ConsistentHash.locateAllOwners(Collection<Object> keys)	Deprecated. Since 9.0, please use LocalizedCacheTopology.getWriteOwners(Collection) instead.
default List<Address>	ConsistentHash.locateOwners(Object key)	Deprecated. Since 9.0, please use LocalizedCacheTopology.getDistribution(Object) instead.
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.isKeyLocalToNode(Address nodeAddress, Object key)	Deprecated. Since 9.0, please use LocalizedCacheTopology.isReadOwner(Object) and LocalizedCacheTopology.isWriteOwner(Object) instead.
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(org.infinispan.commons.hash.Hash hashFunction, int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)	Create a new consistent hash instance.
CH	ConsistentHashFactory.create(org.infinispan.commons.hash.Hash hashFunction, int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)	Create a new consistent hash instance.
default ConsistentHash	ConsistentHash.remapAddresses(UnaryOperator<Address> remapper)	Returns a new ConsistentHash with the addresses remapped according to the provided UnaryOperator.
CH	ConsistentHashFactory.updateMembers(CH baseCH, List<Address> newMembers, Map<Address,Float> capacityFactors)	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)	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 Map<Address,Float>	AbstractConsistentHashFactory.Builder.capacityFactors
protected Map<Address,Float>	AbstractConsistentHashFactory.Builder.capacityFactors
protected Map<Address,Float>	SyncConsistentHashFactory.Builder.capacityFactors
protected List<Address>	AbstractConsistentHash.members	The membership of the cache topology that uses this CH.
protected List<Address>	AbstractConsistentHashFactory.Builder.members
protected List<Address>	AbstractConsistentHashFactory.Builder.members
protected List<Address>	SyncConsistentHashFactory.Builder.sortedMembers

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	ScatteredConsistentHashFactory.Builder.getPrimaryOwner(int segment)
Address	DefaultConsistentHash.locatePrimaryOwnerForSegment(int segmentId)
Address	ReplicatedConsistentHash.locatePrimaryOwnerForSegment(int segmentId)
Address	ScatteredConsistentHash.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()
List<Address>	AbstractConsistentHash.getMembers()
List<Address>	ReplicatedConsistentHash.getMembers()
List<Address>	DefaultConsistentHashFactory.Builder.getOwners(int segment)
Set<Address>	ReplicatedConsistentHash.locateAllOwners(Collection<Object> keys)
Set<Address>	ScatteredConsistentHash.locateAllOwners(Collection<Object> keys)
List<Address>	DefaultConsistentHash.locateOwnersForSegment(int segmentId)
List<Address>	ReplicatedConsistentHash.locateOwnersForSegment(int segmentId)
List<Address>	ScatteredConsistentHash.locateOwnersForSegment(int segmentId)
protected static List<Address>	AbstractConsistentHash.parseMembers(ScopedPersistentState state)
protected Map<Address,Float>	AbstractConsistentHash.remapCapacityFactors(UnaryOperator<Address> remapper)
protected List<Address>	AbstractConsistentHash.remapMembers(UnaryOperator<Address> remapper)
protected List<Address>	SyncConsistentHashFactory.Builder.sort(List<Address> members, Map<Address,Float> capacityFactors)
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
protected boolean	SyncConsistentHashFactory.Builder.addBackupOwner(int segment, Address candidate)
protected boolean	TopologyAwareSyncConsistentHashFactory.Builder.addBackupOwner(int segment, Address candidate)
boolean	DefaultConsistentHashFactory.Builder.addOwner(int segment, Address owner)
protected void	SyncConsistentHashFactory.Builder.addOwnerNoCheck(int segment, Address owner)
void	DefaultConsistentHashFactory.Builder.addPrimaryOwner(int segment, Address newPrimaryOwner)
void	ScatteredConsistentHashFactory.Builder.addPrimaryOwner(int segment, Address newPrimaryOwner)
protected boolean	SyncConsistentHashFactory.Builder.addPrimaryOwner(int segment, Address candidate)
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)
protected double	SyncConsistentHashFactory.Builder.getExpectedOwnedSegments(Address node)
protected double	TopologyAwareSyncConsistentHashFactory.Builder.getExpectedOwnedSegments(Address node)
protected double	SyncConsistentHashFactory.Builder.getExpectedPrimarySegments(Address node)
protected double	TopologyAwareSyncConsistentHashFactory.Builder.getExpectedPrimarySegments(Address node)
int	DefaultConsistentHashFactory.Builder.getOwned(Address node)
int	OwnershipStatistics.getOwned(Address a)
int	ScatteredConsistentHashFactory.Builder.getOwned(Address node)
float	DefaultConsistentHashFactory.Builder.getOwnedPerCapacity(Address node)
int	DefaultConsistentHashFactory.Builder.getPrimaryOwned(Address node)
int	OwnershipStatistics.getPrimaryOwned(Address a)
int	ScatteredConsistentHashFactory.Builder.getPrimaryOwned(Address node)
float	DefaultConsistentHashFactory.Builder.getPrimaryOwnedPerCapacity(Address node)
Set<Integer>	DefaultConsistentHash.getPrimarySegmentsForOwner(Address owner)
Set<Integer>	ReplicatedConsistentHash.getPrimarySegmentsForOwner(Address owner)
Set<Integer>	ScatteredConsistentHash.getPrimarySegmentsForOwner(Address owner)
Set<Integer>	DefaultConsistentHash.getSegmentsForOwner(Address owner)
Set<Integer>	ReplicatedConsistentHash.getSegmentsForOwner(Address owner)
Set<Integer>	ScatteredConsistentHash.getSegmentsForOwner(Address owner)
void	OwnershipStatistics.incOwned(Address a)
void	OwnershipStatistics.incPrimaryOwned(Address a)
boolean	AbstractConsistentHash.isKeyLocalToNode(Address nodeAddress, Object key)
boolean	ReplicatedConsistentHash.isKeyLocalToNode(Address nodeAddress, Object key)
boolean	DefaultConsistentHash.isSegmentLocalToNode(Address nodeAddress, int segmentId)
boolean	ReplicatedConsistentHash.isSegmentLocalToNode(Address nodeAddress, int segmentId)
boolean	ScatteredConsistentHash.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 boolean	SyncConsistentHashFactory.Builder.canAddOwners(List<Address> owners)
protected boolean	TopologyAwareSyncConsistentHashFactory.Builder.canAddOwners(List<Address> owners)
protected void	AbstractConsistentHashFactory.checkCapacityFactors(List<Address> members, Map<Address,Float> capacityFactors)
protected void	AbstractConsistentHashFactory.checkCapacityFactors(List<Address> members, Map<Address,Float> capacityFactors)
protected void	SyncConsistentHashFactory.checkCapacityFactors(List<Address> members, Map<Address,Float> capacityFactors)
protected void	SyncConsistentHashFactory.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(org.infinispan.commons.hash.Hash hashFunction, int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
DefaultConsistentHash	DefaultConsistentHashFactory.create(org.infinispan.commons.hash.Hash hashFunction, int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
ReplicatedConsistentHash	ReplicatedConsistentHashFactory.create(org.infinispan.commons.hash.Hash hashFunction, int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
ReplicatedConsistentHash	ReplicatedConsistentHashFactory.create(org.infinispan.commons.hash.Hash hashFunction, int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
ScatteredConsistentHash	ScatteredConsistentHashFactory.create(org.infinispan.commons.hash.Hash hashFunction, int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
ScatteredConsistentHash	ScatteredConsistentHashFactory.create(org.infinispan.commons.hash.Hash hashFunction, int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
DefaultConsistentHash	SyncConsistentHashFactory.create(org.infinispan.commons.hash.Hash hashFunction, int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
DefaultConsistentHash	SyncConsistentHashFactory.create(org.infinispan.commons.hash.Hash hashFunction, int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
ReplicatedConsistentHash	SyncReplicatedConsistentHashFactory.create(org.infinispan.commons.hash.Hash hashFunction, int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
ReplicatedConsistentHash	SyncReplicatedConsistentHashFactory.create(org.infinispan.commons.hash.Hash hashFunction, int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
protected SyncConsistentHashFactory.Builder	SyncConsistentHashFactory.createBuilder(org.infinispan.commons.hash.Hash hashFunction, int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
protected SyncConsistentHashFactory.Builder	SyncConsistentHashFactory.createBuilder(org.infinispan.commons.hash.Hash hashFunction, int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
protected TopologyAwareSyncConsistentHashFactory.Builder	TopologyAwareSyncConsistentHashFactory.createBuilder(org.infinispan.commons.hash.Hash hashFunction, int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
protected TopologyAwareSyncConsistentHashFactory.Builder	TopologyAwareSyncConsistentHashFactory.createBuilder(org.infinispan.commons.hash.Hash hashFunction, 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	ScatteredConsistentHash.remapAddresses(UnaryOperator<Address> remapper)
protected Map<Address,Float>	AbstractConsistentHash.remapCapacityFactors(UnaryOperator<Address> remapper)
protected List<Address>	AbstractConsistentHash.remapMembers(UnaryOperator<Address> remapper)
protected List<Address>	SyncConsistentHashFactory.Builder.sort(List<Address> members, Map<Address,Float> capacityFactors)
protected List<Address>	SyncConsistentHashFactory.Builder.sort(List<Address> members, Map<Address,Float> capacityFactors)
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)
ScatteredConsistentHash	ScatteredConsistentHashFactory.updateMembers(ScatteredConsistentHash baseCH, List<Address> actualMembers, Map<Address,Float> actualCapacityFactors)	Leavers are removed and segments without owners are assigned new owners.
ScatteredConsistentHash	ScatteredConsistentHashFactory.updateMembers(ScatteredConsistentHash baseCH, List<Address> actualMembers, Map<Address,Float> actualCapacityFactors)	Leavers are removed and segments without owners are assigned new owners.
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)

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

Constructor	Description
ScatteredConsistentHash(org.infinispan.commons.hash.Hash hashFunction, int numSegments, List<Address> members, Map<Address,Float> capacityFactors, Address[] segmentOwners, boolean isRebalanced)

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

Constructor	Description
AbstractConsistentHash(org.infinispan.commons.hash.Hash hashFunction, int numSegments, List<Address> members, float[] capacityFactors)
AbstractConsistentHash(org.infinispan.commons.hash.Hash hashFunction, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
AbstractConsistentHash(org.infinispan.commons.hash.Hash hashFunction, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
Builder(org.infinispan.commons.hash.Hash hashFunction, int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
Builder(org.infinispan.commons.hash.Hash hashFunction, 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)
Builder(org.infinispan.commons.hash.Hash hashFunction, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
Builder(org.infinispan.commons.hash.Hash hashFunction, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
Builder(ScatteredConsistentHash baseCH, List<Address> actualMembers, Map<Address,Float> actualCapacityFactors)
Builder(ScatteredConsistentHash baseCH, List<Address> actualMembers, Map<Address,Float> actualCapacityFactors)
Builder(org.infinispan.commons.hash.Hash hashFunction, int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
Builder(org.infinispan.commons.hash.Hash hashFunction, int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
Builder(org.infinispan.commons.hash.Hash hashFunction, int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
Builder(org.infinispan.commons.hash.Hash hashFunction, int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
DefaultConsistentHash(org.infinispan.commons.hash.Hash hashFunction, int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors, List<Address>[] segmentOwners)
DefaultConsistentHash(org.infinispan.commons.hash.Hash hashFunction, 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(org.infinispan.commons.hash.Hash hashFunction, List<Address> members, int[] primaryOwners)
ScatteredConsistentHash(org.infinispan.commons.hash.Hash hashFunction, int numSegments, List<Address> members, Map<Address,Float> capacityFactors, Address[] segmentOwners, boolean isRebalanced)
ScatteredConsistentHash(org.infinispan.commons.hash.Hash hashFunction, int numSegments, List<Address> members, Map<Address,Float> capacityFactors, Address[] segmentOwners, boolean isRebalanced)

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

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

Modifier and Type	Method	Description
Address	GroupManager.getPrimaryOwner(Object group)	Deprecated. Since 9.0, please use DistributionManager.getCacheTopology() instead.
Address	GroupManagerImpl.getPrimaryOwner(Object group)
Address	PartitionerConsistentHash.locatePrimaryOwnerForSegment(int segmentId)

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

Modifier and Type	Method	Description
List<Address>	PartitionerConsistentHash.getMembers()
List<Address>	PartitionerConsistentHash.locateOwnersForSegment(int segmentId)

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

Modifier and Type	Method	Description
Set<Integer>	PartitionerConsistentHash.getPrimarySegmentsForOwner(Address owner)
Set<Integer>	PartitionerConsistentHash.getSegmentsForOwner(Address owner)
boolean	PartitionerConsistentHash.isKeyLocalToNode(Address nodeAddress, Object key)
boolean	PartitionerConsistentHash.isSegmentLocalToNode(Address nodeAddress, int segmentId)

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

Modifier and Type	Method	Description
ConsistentHash	PartitionerConsistentHash.remapAddresses(UnaryOperator<Address> remapper)

Uses of Address in org.infinispan.distribution.impl

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

Modifier and Type	Method	Description
Address	DistributionManagerImpl.getPrimaryLocation(Object key)

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

Modifier and Type	Method	Description
List<Address>	DistributionManagerImpl.locate(Object key)
Set<Address>	DistributionManagerImpl.locateAll(Collection<Object> keys)

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)

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

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.interceptors.distribution

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

Modifier and Type	Method	Description
void	BiasedCollector.addPendingAcks(boolean success, Address[] waitFor)
default ValidResponse	BiasedCollector.addResponse(Address sender, Response response)
SuccessfulResponse	RemoteGetSingleKeyCollector.addResponse(Address sender, Response response)
protected void	BiasedScatteredDistributionInterceptor.completeManyWriteOnPrimaryOriginator(org.infinispan.commands.write.WriteCommand command, Address backup, org.infinispan.interceptors.distribution.CountDownCompletableFuture future)
protected void	ScatteredDistributionInterceptor.completeManyWriteOnPrimaryOriginator(org.infinispan.commands.write.WriteCommand command, Address backup, org.infinispan.interceptors.distribution.CountDownCompletableFuture future)	This is a hook for bias-enabled mode where the primary performs additional RPCs but replication to another node.
protected CompletionStage<?>	BiasedScatteredDistributionInterceptor.completeSingleWriteOnPrimaryOriginator(org.infinispan.commands.write.DataWriteCommand command, Address backup, CompletionStage<?> rpcFuture)
protected CompletionStage<?>	ScatteredDistributionInterceptor.completeSingleWriteOnPrimaryOriginator(org.infinispan.commands.write.DataWriteCommand command, Address backup, CompletionStage<?> rpcFuture)	This is a hook for bias-enabled mode where the primary performs additional RPCs but replication to another node.
protected Object	BaseDistributionInterceptor.invokeRemotely(InvocationContext ctx, org.infinispan.commands.write.DataWriteCommand command, Address primaryOwner)
protected CompletionStage<ValidResponse>	BiasedScatteredDistributionInterceptor.manyWriteOnRemotePrimary(Address target, org.infinispan.commands.write.WriteCommand command, CommandAckCollector.MultiTargetCollector multiTargetCollector)
protected CompletionStage<ValidResponse>	ScatteredDistributionInterceptor.manyWriteOnRemotePrimary(Address target, org.infinispan.commands.write.WriteCommand command, CommandAckCollector.MultiTargetCollector multiTargetCollector)
protected CompletionStage<ValidResponse>	BiasedScatteredDistributionInterceptor.singleWriteOnRemotePrimary(Address target, org.infinispan.commands.write.DataWriteCommand command)
protected CompletionStage<ValidResponse>	ScatteredDistributionInterceptor.singleWriteOnRemotePrimary(Address target, org.infinispan.commands.write.DataWriteCommand command)	This method is called by a non-owner sending write request to the primary owner

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

Modifier and Type	Method	Description
protected void	TxDistributionInterceptor.checkTxCommandResponses(Map<Address,Response> responseMap, org.infinispan.commands.tx.TransactionBoundaryCommand command, TxInvocationContext<LocalTransaction> context, Collection<Address> recipients)
protected void	TxDistributionInterceptor.checkTxCommandResponses(Map<Address,Response> responseMap, org.infinispan.commands.tx.TransactionBoundaryCommand command, TxInvocationContext<LocalTransaction> context, Collection<Address> recipients)
CompletionStage<Void>	BaseDistributionInterceptor.ReadManyCommandHelper.fetchRequiredKeys(LocalizedCacheTopology cacheTopology, Map<Address,List<Object>> requestedKeys, List<Object> availableKeys, InvocationContext ctx, C command)
CompletionStage<Void>	BaseDistributionInterceptor.ReadOnlyManyHelper.fetchRequiredKeys(LocalizedCacheTopology cacheTopology, Map<Address,List<Object>> requestedKeys, List<Object> availableKeys, InvocationContext ctx, org.infinispan.commands.functional.ReadOnlyManyCommand command)
protected CompletionStage<Object>	TxDistributionInterceptor.prepareOnAffectedNodes(TxInvocationContext<?> ctx, org.infinispan.commands.tx.PrepareCommand command, Collection<Address> recipients)
protected CompletionStage<Object>	VersionedDistributionInterceptor.prepareOnAffectedNodes(TxInvocationContext<?> ctx, org.infinispan.commands.tx.PrepareCommand command, Collection<Address> recipients)

Uses of Address in org.infinispan.interceptors.impl

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

Modifier and Type	Method	Description
protected static SuccessfulResponse	ClusteringInterceptor.getSuccessfulResponseOrFail(Map<Address,Response> responseMap, CompletableFuture<?> future, Consumer<Response> cacheNotFound)
protected CompletionStage<Object>	BaseRpcInterceptor.totalOrderPrepare(TxInvocationContext<?> ctx, org.infinispan.commands.tx.PrepareCommand command, Collection<Address> recipients)

Uses of Address in org.infinispan.interceptors.locking

Methods in org.infinispan.interceptors.locking that return Address

Modifier and Type	Method	Description
Address	ClusteringDependentLogic.AbstractClusteringDependentLogic.getAddress()
Address	ClusteringDependentLogic.getAddress()
Address	ClusteringDependentLogic.LocalLogic.getAddress()
default Address	ClusteringDependentLogic.getPrimaryOwner(Object key)	Deprecated. Since 9.0, please use getCacheTopology().getDistributionInfo(key).primary() instead.

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

Modifier and Type	Method	Description
default Collection<Address>	ClusteringDependentLogic.getOwners(Object key)	Deprecated. Since 9.0, please use getCacheTopology().getWriteOwners(key) instead.
default Collection<Address>	ClusteringDependentLogic.getOwners(Collection<Object> keys)	Deprecated. Since 9.0, please use getCacheTopology().getWriteOwners(keys) instead.
Collection<Address>	ClusteringDependentLogic.ReplicationLogic.getOwners(Object key)
Collection<Address>	ClusteringDependentLogic.ReplicationLogic.getOwners(Collection<Object> keys)

Uses of Address in org.infinispan.interceptors.totalorder

Method parameters in org.infinispan.interceptors.totalorder with type arguments of type Address

Modifier and Type	Method	Description
protected CompletionStage<Object>	TotalOrderDistributionInterceptor.prepareOnAffectedNodes(TxInvocationContext<?> ctx, org.infinispan.commands.tx.PrepareCommand command, Collection<Address> recipients)
protected CompletionStage<Object>	TotalOrderVersionedDistributionInterceptor.prepareOnAffectedNodes(TxInvocationContext<?> ctx, org.infinispan.commands.tx.PrepareCommand command, Collection<Address> recipients)

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, JGroupsTransport transport, long time, TimeUnit unit, Executor localExecutor, ScheduledExecutorService timeoutExecutor)
static ClusterExecutor	ClusterExecutors.singleNodeSubmissionExecutor(Predicate<? super Address> predicate, EmbeddedCacheManager manager, JGroupsTransport transport, long time, TimeUnit unit, Executor localExecutor, 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(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

Constructor	Description
ClusterListenerReplicateCallable(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, DistributedExecutorService distExecService, 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 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(Address target, UUID identifier, Collection<ClusterEvent<K,V>> events, boolean sync)
void	ClusterEventManagerStub.addEvents(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
void	CacheManagerNotifier.notifyMerge(List<Address> members, List<Address> oldMembers, Address myAddress, int viewId, List<List<Address>> subgroupsMerged)
void	CacheManagerNotifierImpl.notifyMerge(List<Address> members, List<Address> oldMembers, Address myAddress, int viewId, List<List<Address>> subgroupsMerged)
void	CacheManagerNotifier.notifyViewChange(List<Address> members, List<Address> oldMembers, Address myAddress, int viewId)	Notifies all registered listeners of a viewChange event.
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
void	CacheManagerNotifier.notifyMerge(List<Address> members, List<Address> oldMembers, Address myAddress, int viewId, List<List<Address>> subgroupsMerged)
void	CacheManagerNotifierImpl.notifyMerge(List<Address> members, List<Address> oldMembers, Address myAddress, int viewId, List<List<Address>> subgroupsMerged)
void	CacheManagerNotifier.notifyViewChange(List<Address> members, List<Address> oldMembers, Address myAddress, int viewId)	Notifies all registered listeners of a viewChange event.
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

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

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, EntryVersionsMap newVersions)
boolean	PartitionHandlingManager.addPartialCommit2PCTransaction(GlobalTransaction globalTransaction, Collection<Address> affectedNodes, Collection<Object> lockedKeys, EntryVersionsMap newVersions)	Adds a partially committed transaction.
boolean	PartitionHandlingManagerImpl.addPartialCommit2PCTransaction(GlobalTransaction globalTransaction, Collection<Address> affectedNodes, Collection<Object> lockedKeys, EntryVersionsMap 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	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 {@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.query.affinity

Methods in org.infinispan.query.affinity that return Address

Modifier and Type	Method	Description
Address	ShardAllocationManagerImpl.getOwner(String shardId)
Address	ShardAllocatorManager.getOwner(String shardId)

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

Modifier and Type	Method	Description
Set<String>	ShardAllocationManagerImpl.getShardsForModification(Address address)
Set<String>	ShardAllocatorManager.getShardsForModification(Address address)

Uses of Address in org.infinispan.query.clustered

Fields in org.infinispan.query.clustered declared as Address

Modifier and Type	Field	Description
Address	NodeTopDocs.address

Constructors in org.infinispan.query.clustered with parameters of type Address

Constructor	Description
NodeTopDocs(Address address, org.apache.lucene.search.TopDocs topDocs)
NodeTopDocs(Address address, org.apache.lucene.search.TopDocs topDocs, Object[] keys, Object[] projections)

Uses of Address in org.infinispan.query.logging

Methods in org.infinispan.query.logging with parameters of type Address

Modifier and Type	Method	Description
void	Log_$logger.workListRemotedTo(Object workList, Address primaryNodeAddress)
void	Log.workListRemotedTo(Object workList, Address primaryNodeAddress)

Uses of Address in org.infinispan.remoting

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

Modifier and Type	Method	Description
static LocalInvocation	LocalInvocation.newInstance(ResponseGenerator responseGenerator, org.infinispan.commands.remote.CacheRpcCommand command, CommandsFactory commandsFactory, Address self)

Uses of Address in org.infinispan.remoting.inboundhandler

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

Modifier and Type	Method	Description
void	GlobalInboundInvocationHandler.handleFromCluster(Address origin, ReplicableCommand command, Reply reply, DeliverOrder order)
void	InboundInvocationHandler.handleFromCluster(Address origin, ReplicableCommand command, Reply reply, DeliverOrder order)	Handles the ReplicableCommand from other node belonging to local site.

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

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

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()
Map<Address,Response>	RpcManager.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, RpcOptions options)	Deprecated. Since 9.2, please use RpcManager.invokeCommand(Collection, ReplicableCommand, ResponseCollector, RpcOptions) instead.
Map<Address,Response>	RpcManager.invokeRemotely(Map<Address,ReplicableCommand> rpcs, RpcOptions options)	Deprecated. Since 9.2, please use RpcManager.invokeCommands(Collection, Function, ResponseCollector, RpcOptions) instead.
Map<Address,Response>	RpcManagerImpl.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, RpcOptions options)
Map<Address,Response>	RpcManagerImpl.invokeRemotely(Map<Address,ReplicableCommand> rpcs, RpcOptions options)
CompletableFuture<Map<Address,Response>>	RpcManager.invokeRemotelyAsync(Collection<Address> recipients, ReplicableCommand rpc, RpcOptions options)	Invokes a command on remote nodes.
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, DeliverOrder deliverOrder)	Asynchronously sends the ReplicableCommand to the destination using the specified DeliverOrder.
void	RpcManagerImpl.sendTo(Address destination, ReplicableCommand command, 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)
Map<Address,Response>	RpcManager.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, RpcOptions options)	Deprecated. Since 9.2, please use RpcManager.invokeCommand(Collection, ReplicableCommand, ResponseCollector, RpcOptions) instead.
Map<Address,Response>	RpcManager.invokeRemotely(Map<Address,ReplicableCommand> rpcs, RpcOptions options)	Deprecated. Since 9.2, please use RpcManager.invokeCommands(Collection, Function, ResponseCollector, RpcOptions) instead.
Map<Address,Response>	RpcManagerImpl.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, RpcOptions options)
Map<Address,Response>	RpcManagerImpl.invokeRemotely(Map<Address,ReplicableCommand> rpcs, RpcOptions options)
CompletableFuture<Map<Address,Response>>	RpcManager.invokeRemotelyAsync(Collection<Address> recipients, ReplicableCommand rpc, RpcOptions options)	Invokes a command on remote nodes.
CompletableFuture<Map<Address,Response>>	RpcManagerImpl.invokeRemotelyAsync(Collection<Address> recipients, ReplicableCommand rpc, RpcOptions options)
void	RpcManager.sendToMany(Collection<Address> destinations, ReplicableCommand command, DeliverOrder deliverOrder)	Asynchronously sends the ReplicableCommand to the set of destination using the specified DeliverOrder.
void	RpcManagerImpl.sendToMany(Collection<Address> destinations, ReplicableCommand command, 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.

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

Modifier and Type	Field	Description
static Address[]	Address.EMPTY_ARRAY
static 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
protected Map<Address,Response>	AbstractDelegatingTransport.afterInvokeRemotely(ReplicableCommand command, Map<Address,Response> responseMap)	method invoked after a successful remote invocation.
List<Address>	AbstractDelegatingTransport.getMembers()
List<Address>	Transport.getMembers()	Returns a list of members in the current cluster view.
List<Address>	AbstractDelegatingTransport.getPhysicalAddresses()
List<Address>	Transport.getPhysicalAddresses()	Retrieves the current cache instance's physical network addresses.
Map<Address,Response>	AbstractDelegatingTransport.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, ResponseFilter responseFilter, DeliverOrder deliverOrder, boolean anycast)
Map<Address,Response>	AbstractDelegatingTransport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter, boolean totalOrder, boolean anycast)
Map<Address,Response>	AbstractDelegatingTransport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands, ResponseMode mode, long timeout, ResponseFilter responseFilter, DeliverOrder deliverOrder, boolean anycast)
default Map<Address,Response>	Transport.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, ResponseFilter responseFilter, DeliverOrder deliverOrder, boolean anycast)	Deprecated. Since 9.2, please use Transport.invokeCommand(Collection, ReplicableCommand, ResponseCollector, DeliverOrder, long, TimeUnit) instead.
default Map<Address,Response>	Transport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter, boolean totalOrder, boolean anycast)	Deprecated. 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, DeliverOrder deliverOrder, boolean anycast)	Deprecated. 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, DeliverOrder deliverOrder, boolean anycast)
CompletableFuture<Map<Address,Response>>	Transport.invokeRemotelyAsync(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, ResponseFilter responseFilter, 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.
T	ValidResponseCollector.addResponse(Address sender, Response response)
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.
Response	AbstractTransport.checkResponse(Object responseObject, Address sender, boolean ignoreCacheNotFoundResponse)	Deprecated.
int	LocalModeAddress.compareTo(Address o)
<T> CompletionStage<T>	AbstractDelegatingTransport.invokeCommand(Address target, ReplicableCommand command, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, TimeUnit unit)
default <T> CompletionStage<T>	Transport.invokeCommand(Address target, ReplicableCommand command, ResponseCollector<T> collector, 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, DeliverOrder deliverOrder)
void	Transport.sendTo(Address destination, ReplicableCommand rpcCommand, 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
protected Map<Address,Response>	AbstractDelegatingTransport.afterInvokeRemotely(ReplicableCommand command, Map<Address,Response> responseMap)	method invoked after a successful remote invocation.
<T> CompletionStage<T>	AbstractDelegatingTransport.invokeCommand(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, TimeUnit unit)
default <T> CompletionStage<T>	Transport.invokeCommand(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, 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, 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, DeliverOrder deliverOrder, long timeout, TimeUnit timeUnit)
<T> CompletionStage<T>	AbstractDelegatingTransport.invokeCommands(Collection<Address> targets, Function<Address,ReplicableCommand> commandGenerator, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, TimeUnit timeUnit)
default <T> CompletionStage<T>	Transport.invokeCommands(Collection<Address> targets, Function<Address,ReplicableCommand> commandGenerator, ResponseCollector<T> responseCollector, long timeout, DeliverOrder deliverOrder)	Deprecated. 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, DeliverOrder deliverOrder)	Deprecated. 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, 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, 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, DeliverOrder deliverOrder, long timeout, TimeUnit unit)
default <T> CompletionStage<T>	Transport.invokeCommandStaggered(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, 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(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, ResponseFilter responseFilter, DeliverOrder deliverOrder, boolean anycast)
Map<Address,Response>	AbstractDelegatingTransport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter, boolean totalOrder, boolean anycast)
Map<Address,Response>	AbstractDelegatingTransport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands, ResponseMode mode, long timeout, ResponseFilter responseFilter, DeliverOrder deliverOrder, boolean anycast)
default Map<Address,Response>	Transport.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, ResponseFilter responseFilter, DeliverOrder deliverOrder, boolean anycast)	Deprecated. Since 9.2, please use Transport.invokeCommand(Collection, ReplicableCommand, ResponseCollector, DeliverOrder, long, TimeUnit) instead.
default Map<Address,Response>	Transport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter, boolean totalOrder, boolean anycast)	Deprecated. 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, DeliverOrder deliverOrder, boolean anycast)	Deprecated. 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, DeliverOrder deliverOrder, boolean anycast)
CompletableFuture<Map<Address,Response>>	Transport.invokeRemotelyAsync(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, ResponseFilter responseFilter, DeliverOrder deliverOrder, boolean anycast)
void	AbstractDelegatingTransport.sendToMany(Collection<Address> destinations, ReplicableCommand rpcCommand, DeliverOrder deliverOrder)
void	Transport.sendToMany(Collection<Address> destinations, ReplicableCommand rpcCommand, 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 HashMap<Address,Response>	MapResponseCollector.map

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

Modifier and Type	Method	Description
protected Address	MultiTargetRequest.getTarget(int i)

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

Constructor	Description
MultiTargetRequest(ResponseCollector<T> responseCollector, long requestId, RequestRepository repository, Collection<Address> targets, Address excluded)
SingleTargetRequest(ResponseCollector<T> wrapper, long requestId, RequestRepository repository, Address target)

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

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

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
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()
Set<Address>	ClusterView.getMembersSet()
List<Address>	JGroupsTransport.getPhysicalAddresses()
Map<Address,Response>	JGroupsTransport.invokeRemotely(Map<Address,ReplicableCommand> commands, ResponseMode mode, long timeout, ResponseFilter responseFilter, DeliverOrder deliverOrder, boolean anycast)	Deprecated.
CompletableFuture<Map<Address,Response>>	JGroupsTransport.invokeRemotelyAsync(Collection<Address> recipients, ReplicableCommand command, ResponseMode mode, long timeout, ResponseFilter responseFilter, 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, DeliverOrder deliverOrder, long timeout, TimeUnit unit)
void	SingleSiteRequest.onResponse(Address sender, Response response)
void	StaggeredRequest.onResponse(Address sender, Response response)
void	JGroupsTransport.sendTo(Address destination, ReplicableCommand command, DeliverOrder deliverOrder)

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, DeliverOrder deliverOrder, long timeout, TimeUnit unit)
<T> CompletionStage<T>	JGroupsTransport.invokeCommandOnAll(Collection<Address> requiredTargets, ReplicableCommand command, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, TimeUnit unit)
<T> CompletionStage<T>	JGroupsTransport.invokeCommands(Collection<Address> targets, Function<Address,ReplicableCommand> commandGenerator, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, TimeUnit timeUnit)
<T> CompletionStage<T>	JGroupsTransport.invokeCommands(Collection<Address> targets, Function<Address,ReplicableCommand> commandGenerator, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, TimeUnit timeUnit)
<T> CompletionStage<T>	JGroupsTransport.invokeCommandStaggered(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, TimeUnit unit)
Map<Address,Response>	JGroupsTransport.invokeRemotely(Map<Address,ReplicableCommand> commands, ResponseMode mode, long timeout, ResponseFilter responseFilter, DeliverOrder deliverOrder, boolean anycast)	Deprecated.
CompletableFuture<Map<Address,Response>>	JGroupsTransport.invokeRemotelyAsync(Collection<Address> recipients, ReplicableCommand command, ResponseMode mode, long timeout, ResponseFilter responseFilter, DeliverOrder deliverOrder, boolean anycast)
boolean	SingleSiteRequest.onNewView(Set<Address> members)
void	JGroupsTransport.sendToMany(Collection<Address> targets, ReplicableCommand command, DeliverOrder deliverOrder)

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

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

Uses of Address in org.infinispan.scattered

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

Modifier and Type	Method	Description
List<Address>	BiasManager.Revocation.biased()
List<Address>	BiasManager.getRemoteBias(Object key)

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

Modifier and Type	Method	Description
void	BiasManager.renewRemoteBias(Object key, Address origin)	Notify the component that the node is reading the biased entry and the bias should not be revoked unless necessary.
void	ScatteredStateProvider.startKeysTransfer(org.infinispan.commons.util.IntSet segments, Address origin)
BiasManager.Revocation	BiasManager.startRevokingRemoteBias(Object key, Address newBiased)	Check if there are any nodes that have local bias, and starting replacing them with the provided address.

Uses of Address in org.infinispan.scattered.impl

Fields in org.infinispan.scattered.impl with type parameters of type Address

Modifier and Type	Field	Description
protected Collection<Address>	ScatteredStateConsumerImpl.backupAddress
protected ConcurrentMap<Address,BlockingQueue<ScatteredStateConsumerImpl.KeyAndVersion>>	ScatteredStateConsumerImpl.invalidations
protected Collection<Address>	ScatteredStateConsumerImpl.nonBackupAddresses
protected ConcurrentMap<Address,BlockingQueue<Object>>	ScatteredStateConsumerImpl.retrievedEntries

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

Modifier and Type	Method	Description
List<Address>	BiasManagerImpl.getRemoteBias(Object key)

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

Modifier and Type	Method	Description
void	BiasManagerImpl.renewRemoteBias(Object key, Address origin)
void	ScatteredStateProviderImpl.startKeysTransfer(org.infinispan.commons.util.IntSet segments, Address origin)
BiasManager.Revocation	BiasManagerImpl.startRevokingRemoteBias(Object key, Address newBiased)

Uses of Address in org.infinispan.security.actions

Methods in org.infinispan.security.actions that return Address

Modifier and Type	Method	Description
Address	GetCacheManagerAddress.run()
Address	GetCacheManagerCoordinatorAddress.run()

Uses of Address in org.infinispan.server.hotrod

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

Modifier and Type	Class	Description
class	ServerAddress	A Hot Rod server address

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

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

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

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

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

Modifier and Type	Method	Description
protected org.infinispan.server.hotrod.AbstractHashDistAwareResponse	AbstractEncoder1x.createHashDistAwareResp(int topologyId, Map<Address,ServerAddress> serverEndpointsMap, Configuration cfg)
protected org.infinispan.server.hotrod.AbstractHashDistAwareResponse	AbstractTopologyAwareEncoder1x.createHashDistAwareResp(int topologyId, Map<Address,ServerAddress> serverEndpointsMap, Configuration cfg)

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
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

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

Uses of Address in org.infinispan.statetransfer

Methods in org.infinispan.statetransfer that return Address

Modifier and Type	Method	Description
Address	OutboundTransferTask.getDestination()
Address	InboundTransferTask.getSource()

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

Modifier and Type	Method	Description
Map<Address,Response>	StateTransferManager.forwardCommandIfNeeded(TopologyAffectedCommand command, Set<Object> affectedKeys, Address origin)	If there is an state transfer happening at the moment, this method forwards the supplied command to the nodes that are new owners of the data, in order to assure consistency.
Map<Address,Response>	StateTransferManagerImpl.forwardCommandIfNeeded(TopologyAffectedCommand command, Set<Object> affectedKeys, Address origin)

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

Modifier and Type	Method	Description
void	StateConsumer.applyState(Address sender, int topologyId, boolean pushTransfer, Collection<StateChunk> stateChunks)
void	StateConsumerImpl.applyState(Address sender, int topologyId, boolean pushTransfer, Collection<StateChunk> stateChunks)
void	StateProvider.cancelOutboundTransfer(Address destination, int topologyId, org.infinispan.commons.util.IntSet segments)	Cancel sending of cache entries that belong to the given set of segments.
void	StateProviderImpl.cancelOutboundTransfer(Address destination, int topologyId, org.infinispan.commons.util.IntSet segments)
Map<Address,Response>	StateTransferManager.forwardCommandIfNeeded(TopologyAffectedCommand command, Set<Object> affectedKeys, Address origin)	If there is an state transfer happening at the moment, this method forwards the supplied command to the nodes that are new owners of the data, in order to assure consistency.
Map<Address,Response>	StateTransferManagerImpl.forwardCommandIfNeeded(TopologyAffectedCommand command, Set<Object> affectedKeys, Address origin)
List<TransactionInfo>	StateProvider.getTransactionsForSegments(Address destination, int topologyId, org.infinispan.commons.util.IntSet segments)	Gets the list of transactions that affect keys from the given segments.
List<TransactionInfo>	StateProviderImpl.getTransactionsForSegments(Address destination, int requestTopologyId, org.infinispan.commons.util.IntSet segments)
void	StateProvider.startOutboundTransfer(Address destination, int topologyId, org.infinispan.commons.util.IntSet segments, boolean applyState)	Start to send cache entries that belong to the given set of segments.
void	StateProviderImpl.startOutboundTransfer(Address destination, int requestTopologyId, org.infinispan.commons.util.IntSet segments, boolean applyState)

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

Constructor	Description
InboundTransferTask(org.infinispan.commons.util.IntSet segments, Address source, int topologyId, RpcManager rpcManager, CommandsFactory commandsFactory, long timeout, String cacheName, boolean applyState)
OutboundTransferTask(Address destination, org.infinispan.commons.util.IntSet segments, int segmentCount, int chunkSize, int topologyId, KeyPartitioner keyPartitioner, Consumer<OutboundTransferTask> onCompletion, Consumer<List<StateChunk>> onChunkReplicated, BiFunction<InternalCacheEntry,InternalEntryFactory,InternalCacheEntry> mapEntryFromDataContainer, BiFunction<MarshalledEntry,InternalEntryFactory,InternalCacheEntry> mapEntryFromStore, InternalDataContainer dataContainer, PersistenceManager persistenceManager, RpcManager rpcManager, CommandsFactory commandsFactory, InternalEntryFactory ef, long timeout, String cacheName, boolean applyState, boolean pushTransfer)
StateRequestCommand(ByteString cacheName, StateRequestCommand.Type type, Address origin, int topologyId, org.infinispan.commons.util.IntSet segments)
StateResponseCommand(ByteString cacheName, Address origin, int topologyId, Collection<StateChunk> stateChunks, boolean applyState, boolean pushTransfer)

Uses of Address in org.infinispan.stats.wrappers

Methods in org.infinispan.stats.wrappers that return Address

Modifier and Type	Method	Description
Address	ExtendedStatisticRpcManager.getAddress()

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

Modifier and Type	Method	Description
List<Address>	ExtendedStatisticRpcManager.getMembers()
Map<Address,Response>	ExtendedStatisticRpcManager.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, RpcOptions options)
Map<Address,Response>	ExtendedStatisticRpcManager.invokeRemotely(Map<Address,ReplicableCommand> rpcs, RpcOptions options)
CompletableFuture<Map<Address,Response>>	ExtendedStatisticRpcManager.invokeRemotelyAsync(Collection<Address> recipients, ReplicableCommand rpc, RpcOptions options)

Methods in org.infinispan.stats.wrappers with parameters of type Address

Modifier and Type	Method	Description
<T> CompletionStage<T>	ExtendedStatisticRpcManager.invokeCommand(Address target, ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)
void	ExtendedStatisticRpcManager.sendTo(Address destination, ReplicableCommand command, DeliverOrder deliverOrder)

Method parameters in org.infinispan.stats.wrappers with type arguments of type Address

Modifier and Type	Method	Description
<T> CompletionStage<T>	ExtendedStatisticRpcManager.invokeCommand(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)
<T> CompletionStage<T>	ExtendedStatisticRpcManager.invokeCommands(Collection<Address> targets, Function<Address,ReplicableCommand> commandGenerator, ResponseCollector<T> collector, RpcOptions rpcOptions)
<T> CompletionStage<T>	ExtendedStatisticRpcManager.invokeCommands(Collection<Address> targets, Function<Address,ReplicableCommand> commandGenerator, ResponseCollector<T> collector, RpcOptions rpcOptions)
<T> CompletionStage<T>	ExtendedStatisticRpcManager.invokeCommandStaggered(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)
Map<Address,Response>	ExtendedStatisticRpcManager.invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, RpcOptions options)
Map<Address,Response>	ExtendedStatisticRpcManager.invokeRemotely(Map<Address,ReplicableCommand> rpcs, RpcOptions options)
CompletableFuture<Map<Address,Response>>	ExtendedStatisticRpcManager.invokeRemotelyAsync(Collection<Address> recipients, ReplicableCommand rpc, RpcOptions options)
void	ExtendedStatisticRpcManager.sendToMany(Collection<Address> destinations, ReplicableCommand command, DeliverOrder deliverOrder)

Uses of Address in org.infinispan.stream.impl

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

Modifier and Type	Field	Description
protected Address	AbstractCacheStream.localAddress
protected Address	ClusterStreamManagerImpl.localAddress

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

Modifier and Type	Method	Description
void	IteratorHandler.closeIterator(Address origin, Object requestId)	Invoked to have handler forget about given iterator they requested.
protected static void	ClusterStreamManagerImpl.markTrackerWithException(org.infinispan.stream.impl.ClusterStreamManagerImpl.RequestTracker<?> tracker, Address dest, Throwable e, Object uuid)
void	ClusterStreamManager.ResultsCallback.onCompletion(Address address, org.infinispan.commons.util.IntSet completedSegments, R results)	Essentially the same as ClusterStreamManager.ResultsCallback.onIntermediateResult(Address address, Object) except that this is the last time this callback will be invoked and it tells which segments were completed
void	ClusterStreamManager.ResultsCallback.onIntermediateResult(Address address, R results)	Called back for intermediate data returned from an operation.
<R1> boolean	ClusterStreamManager.receiveResponse(Object id, Address origin, boolean complete, org.infinispan.commons.util.IntSet segments, R1 response)	Receives a response for a given request
<R1> boolean	ClusterStreamManagerImpl.receiveResponse(Object id, Address origin, boolean complete, org.infinispan.commons.util.IntSet missingSegments, R1 response)
<Original,E> IteratorHandler.OnCloseIterator<E>	IteratorHandler.start(Address origin, Supplier<Stream<Original>> streamSupplier, Iterable<org.infinispan.stream.impl.intops.IntermediateOperation> intOps, Object requestId)	Starts an iteration process from the given stream that converts the stream to a subsequent stream using the given intermediate operations and then creates a managed iterator for the caller to subsequently retrieve.
IteratorResponse	LocalStreamManager.startIterator(Object requestId, Address origin, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, boolean includeLoader, boolean entryStream, Iterable<org.infinispan.stream.impl.intops.IntermediateOperation> intermediateOperations, long batchSize)	Signals that a new iterator is created using the given arguments.
IteratorResponse	LocalStreamManagerImpl.startIterator(Object requestId, Address origin, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, boolean includeLoader, boolean entryStream, Iterable<org.infinispan.stream.impl.intops.IntermediateOperation> intermediateOperations, long batchSize)
<R> void	LocalStreamManager.streamOperation(Object requestId, Address origin, boolean parallelStream, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, boolean includeLoader, boolean entryStream, KeyTrackingTerminalOperation<Original,K,R> operation)	Stream operation for a key aware operation without rehash enabled
<R> void	LocalStreamManager.streamOperation(Object requestId, Address origin, boolean parallelStream, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, boolean includeLoader, boolean entryStream, TerminalOperation<Original,R> operation)	Stream operation for a non key aware operation without rehash enabled.
<R> void	LocalStreamManagerImpl.streamOperation(Object requestId, Address origin, boolean parallelStream, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, boolean includeLoader, boolean entryStream, KeyTrackingTerminalOperation<Original,K,R> operation)
<R> void	LocalStreamManagerImpl.streamOperation(Object requestId, Address origin, boolean parallelStream, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, boolean includeLoader, boolean entryStream, TerminalOperation<Original,R> operation)
void	LocalStreamManager.streamOperationRehashAware(Object requestId, Address origin, boolean parallelStream, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, boolean includeLoader, boolean entryStream, KeyTrackingTerminalOperation<Original,K,?> operation)	Stream operation for a key aware operation with rehash enabled
<R> void	LocalStreamManager.streamOperationRehashAware(Object requestId, Address origin, boolean parallelStream, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, boolean includeLoader, boolean entryStream, TerminalOperation<Original,R> operation)	Stream operation for a non key aware operation with rehash enabled.
void	LocalStreamManagerImpl.streamOperationRehashAware(Object requestId, Address origin, boolean parallelStream, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, boolean includeLoader, boolean entryStream, KeyTrackingTerminalOperation<Original,K,?> operation)
<R> void	LocalStreamManagerImpl.streamOperationRehashAware(Object requestId, Address origin, boolean parallelStream, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, boolean includeLoader, boolean entryStream, TerminalOperation<Original,R> operation)

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

Modifier and Type	Method	Description
<E> ClusterStreamManager.RemoteIteratorPublisher<E>	ClusterStreamManager.remoteIterationPublisher(boolean parallelStream, Supplier<Map.Entry<Address,org.infinispan.commons.util.IntSet>> segments, Set<K> keysToInclude, IntFunction<Set<K>> keysToExclude, boolean includeLoader, boolean entryStream, Iterable<org.infinispan.stream.impl.intops.IntermediateOperation> intermediateOperations)
<E> ClusterStreamManager.RemoteIteratorPublisher<E>	ClusterStreamManagerImpl.remoteIterationPublisher(boolean parallelStream, Supplier<Map.Entry<Address,org.infinispan.commons.util.IntSet>> targets, Set<K> keysToInclude, IntFunction<Set<K>> keysToExclude, boolean includeLoader, boolean entryStream, Iterable<org.infinispan.stream.impl.intops.IntermediateOperation> intermediateOperations)
<E> ClusterStreamManager.RemoteIteratorPublisher<E>	PartitionAwareClusterStreamManager.remoteIterationPublisher(boolean parallelStream, Supplier<Map.Entry<Address,org.infinispan.commons.util.IntSet>> targets, Set<K> keysToInclude, IntFunction<Set<K>> keysToExclude, boolean includeLoader, boolean entryStream, Iterable<org.infinispan.stream.impl.intops.IntermediateOperation> intermediateOperations)

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

Constructor	Description
AbstractCacheStream(Address localAddress, boolean parallel, DistributionManager dm, Supplier<CacheStream<Original>> supplier, ClusterStreamManager<Original,Object> csm, boolean includeLoader, int distributedBatchSize, Executor executor, ComponentRegistry registry, Function<? super Original,?> toKeyFunction)
DistributedCacheStream(Address localAddress, boolean parallel, DistributionManager dm, Supplier<CacheStream<R>> supplier, ClusterStreamManager csm, boolean includeLoader, int distributedBatchSize, Executor executor, ComponentRegistry registry, Function<? super Original,?> toKeyFunction)	Standard constructor requiring all pertinent information to properly utilize a distributed cache stream
StreamIteratorCloseCommand(ByteString cacheName, Address origin, Object id)
StreamIteratorRequestCommand(ByteString cacheName, Address origin, Object id, boolean parallelStream, org.infinispan.commons.util.IntSet segments, Set<K> keys, Set<K> excludedKeys, boolean includeLoader, boolean entryStream, Iterable<org.infinispan.stream.impl.intops.IntermediateOperation> intOps, long batchSize)
StreamRequestCommand(ByteString cacheName, Address origin, Object id, boolean parallelStream, StreamRequestCommand.Type type, org.infinispan.commons.util.IntSet segments, Set<K> keys, Set<K> excludedKeys, boolean includeLoader, boolean entryStream, Object terminalOperation)
StreamResponseCommand(ByteString cacheName, Address origin, Object id, boolean complete, org.infinispan.commons.util.IntSet missedSegments, R response)
StreamResponseCommand(ByteString cacheName, Address origin, Object id, boolean complete, R response)

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)
Address	CacheTopologyControlCommand.getOrigin()

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>	CacheTopology.getActualMembers()
Map<Address,Float>	ClusterCacheStatus.getCapacityFactors()
List<Address>	ClusterCacheStatus.getExpectedMembers()
List<Address>	CacheTopology.getMembers()
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)
boolean	ClusterCacheStatus.doLeave(Address leaver)
PersistentUUID	PersistentUUIDManager.getPersistentUuid(Address address)	Retrieves the PersistentUUID of a node given its Address
PersistentUUID	PersistentUUIDManagerImpl.getPersistentUuid(Address address)
CacheStatusResponse	ClusterTopologyManager.handleJoin(String cacheName, Address joiner, CacheJoinInfo joinInfo, int viewId)	Signals that a new member is joining the cache.
CacheStatusResponse	ClusterTopologyManagerImpl.handleJoin(String cacheName, Address joiner, CacheJoinInfo joinInfo, int joinerViewId)
void	ClusterTopologyManager.handleLeave(String cacheName, Address leaver, int viewId)	Signals that a member is leaving the cache.
void	ClusterTopologyManagerImpl.handleLeave(String cacheName, Address leaver, int viewId)
void	LocalTopologyManager.handleRebalance(String cacheName, CacheTopology cacheTopology, int viewId, Address sender)	Performs the state transfer.
void	LocalTopologyManagerImpl.handleRebalance(String cacheName, CacheTopology cacheTopology, int viewId, Address sender)
void	ClusterTopologyManager.handleRebalancePhaseConfirm(String cacheName, Address node, int topologyId, Throwable throwable, int viewId)	Marks the rebalance as complete on the sender.
void	ClusterTopologyManagerImpl.handleRebalancePhaseConfirm(String cacheName, Address node, int topologyId, Throwable throwable, int viewId)
void	LocalTopologyManager.handleStableTopologyUpdate(String cacheName, CacheTopology cacheTopology, Address sender, int viewId)	Update the stable cache topology.
void	LocalTopologyManagerImpl.handleStableTopologyUpdate(String cacheName, CacheTopology newStableTopology, Address sender, int viewId)
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.
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)
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)
static boolean	ClusterTopologyManagerImpl.scatteredLostDataCheck(ConsistentHash stableCH, List<Address> newMembers)
void	ClusterCacheStatus.updateAvailabilityMode(List<Address> actualMembers, AvailabilityMode newAvailabilityMode, boolean cancelRebalance)
void	ClusterCacheStatus.updateCurrentTopology(List<Address> newMembers)

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

Constructor	Description
CacheTopologyControlCommand(String cacheName, CacheTopologyControlCommand.Type type, Address sender, int viewId)
CacheTopologyControlCommand(String cacheName, CacheTopologyControlCommand.Type type, Address sender, int topologyId, int rebalanceId, Throwable throwable, int viewId)
CacheTopologyControlCommand(String cacheName, CacheTopologyControlCommand.Type type, Address sender, AvailabilityMode availabilityMode, int viewId)
CacheTopologyControlCommand(String cacheName, CacheTopologyControlCommand.Type type, Address sender, CacheJoinInfo joinInfo, int viewId)
CacheTopologyControlCommand(String cacheName, CacheTopologyControlCommand.Type type, Address sender, CacheTopology cacheTopology, AvailabilityMode availabilityMode, int viewId)

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

Constructor	Description
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

Fields in org.infinispan.transaction.xa declared as Address

Modifier and Type	Field	Description
protected Address	GlobalTransaction.addr

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

Constructor	Description
DldGlobalTransaction(Address addr, boolean remote)	Deprecated.
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>	InDoubtTxInfoImpl.getOwners()
Set<Address>	RecoveryManager.InDoubtTxInfo.getOwners()	Returns the set of nodes where this transaction information is maintained.

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

Modifier and Type	Method	Description
void	InDoubtTxInfoImpl.addOwner(Address owner)
String	RecoveryManager.forceTransactionCompletionFromCluster(Xid xid, Address where, boolean commit)	This method invokes RecoveryManager.forceTransactionCompletion(javax.transaction.xa.Xid, boolean) on the specified node.
String	RecoveryManagerImpl.forceTransactionCompletionFromCluster(Xid 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().
void	RecoveryManager.removeRecoveryInformation(Collection<Address> where, Xid xid, boolean sync, 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.
void	RecoveryManagerImpl.removeRecoveryInformation(Collection<Address> lockOwners, Xid xid, boolean sync, GlobalTransaction gtx, boolean fromCluster)
void	RecoveryManager.removeRecoveryInformationFromCluster(Collection<Address> where, long internalId, boolean sync)	Same as RecoveryManager.removeRecoveryInformation(java.util.Collection, javax.transaction.xa.Xid, boolean, org.infinispan.transaction.xa.GlobalTransaction, boolean) but the transaction is identified by its internal id, and not by its xid.
void	RecoveryManagerImpl.removeRecoveryInformationFromCluster(Collection<Address> where, long internalId, boolean sync)

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

Constructor	Description
RecoveryAwareDldGlobalTransaction(Address addr, boolean remote)	Deprecated.
RecoveryAwareGlobalTransaction(Address addr, boolean remote)

Uses of Address in org.infinispan.util

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

Modifier and Type	Method	Description
void	AbstractControlledLocalTopologyManager.handleRebalance(String cacheName, CacheTopology cacheTopology, int viewId, Address sender)
void	AbstractControlledLocalTopologyManager.handleStableTopologyUpdate(String cacheName, CacheTopology cacheTopology, Address sender, int viewId)
void	AbstractControlledLocalTopologyManager.handleTopologyUpdate(String cacheName, CacheTopology cacheTopology, AvailabilityMode availabilityMode, int viewId, Address sender)

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 topologyId)	Acknowledges a write operation completion in the backup owner.
BiasedCollector	CommandAckCollector.MultiTargetCollector.collectorFor(Address target)
void	CommandAckCollector.multiKeyBackupAck(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> Collector<T>	CommandAckCollector.create(long id, Collection<Address> backupOwners, int topologyId)	Creates a collector for a single key write operation.
<T> 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.util.logging

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

Modifier and Type	Method	Description
RuntimeException	Log_$logger.creatingTmpCacheTimedOut(String cacheName, Address address)
RuntimeException	Log.creatingTmpCacheTimedOut(String cacheName, Address address)
void	Log_$logger.distributedTaskFailover(Address failedAtAddress, Address failoverTarget, Exception e)
void	Log.distributedTaskFailover(Address failedAtAddress, Address failoverTarget, Exception e)
void	Log_$logger.errorReadingRebalancingStatus(Address coordinator, Exception e)
void	Log.errorReadingRebalancingStatus(Address coordinator, Exception e)
void	Log_$logger.exceptionDuringClusterListenerRetrieval(Address address, Throwable cause)
void	Log.exceptionDuringClusterListenerRetrieval(Address address, Throwable cause)
void	Log_$logger.failedToRequestSegments(String cacheName, Address source, Collection<Integer> segments, Throwable e)
void	Log.failedToRequestSegments(String cacheName, Address source, Collection<Integer> segments, Throwable e)
void	Log_$logger.failedToRetrieveTransactionsForSegments(String cacheName, Address source, Collection<Integer> segments, Exception e)
void	Log.failedToRetrieveTransactionsForSegments(String cacheName, Address source, Collection<Integer> segments, Exception e)
void	Log_$logger.ignoringUnsolicitedState(Address node, int segment, String cacheName)
void	Log.ignoringUnsolicitedState(Address node, int segment, String cacheName)
void	Log_$logger.localAndPhysicalAddress(String cluster, Address address, List<Address> physicalAddresses)
void	Log.localAndPhysicalAddress(String cluster, Address address, List<Address> physicalAddresses)
CacheJoinException	Log_$logger.nodeWithIncompatibleStateJoiningCache(Address joiner, String cacheName)
CacheJoinException	Log.nodeWithIncompatibleStateJoiningCache(Address joiner, String cacheName)
CacheJoinException	Log_$logger.nodeWithoutPersistentStateJoiningCacheWithState(Address joiner, String cacheName)
CacheJoinException	Log.nodeWithoutPersistentStateJoiningCacheWithState(Address joiner, String cacheName)
CacheJoinException	Log_$logger.nodeWithPersistentStateJoiningClusterWithoutState(Address joiner, String cacheName)
CacheJoinException	Log.nodeWithPersistentStateJoiningClusterWithoutState(Address joiner, String cacheName)
void	Log_$logger.rebalanceError(String cacheName, Address node, int topologyId, Throwable cause)
void	Log.rebalanceError(String cacheName, Address node, int topologyId, Throwable cause)
void	Log_$logger.rebalancePhaseConfirmedOnNode(CacheTopology.Phase phase, String cacheName, Address node, int topologyId)
void	Log.rebalancePhaseConfirmedOnNode(CacheTopology.Phase phase, String cacheName, Address node, int topologyId)
RemoteException	Log_$logger.remoteException(Address sender, Throwable t)
RemoteException	Log.remoteException(Address sender, Throwable t)
void	Log_$logger.remoteExecutionFailed(Address address, Throwable t)
void	Log.remoteExecutionFailed(Address address, Throwable t)
SuspectException	Log_$logger.remoteNodeSuspected(Address address)
SuspectException	Log.remoteNodeSuspected(Address address)
TimeoutException	Log_$logger.remoteNodeTimedOut(Address address, long time, TimeUnit unit)
TimeoutException	Log.remoteNodeTimedOut(Address address, long time, TimeUnit unit)
SuspectException	Log_$logger.thirdPartySuspected(Address sender, SuspectException e)
SuspectException	Log.thirdPartySuspected(Address sender, SuspectException e)
void	Log_$logger.unableToLockToInvalidate(Object key, Address address)
void	Log.unableToLockToInvalidate(Object key, Address address)
void	Log_$logger.unsuccessfulResponseForClusterListeners(Address address, Response response)
void	Log.unsuccessfulResponseForClusterListeners(Address address, Response response)
void	Log_$logger.unsuccessfulResponseRetrievingTransactionsForSegments(Address address, Response response)
void	Log.unsuccessfulResponseRetrievingTransactionsForSegments(Address address, Response response)

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

Modifier and Type	Method	Description
void	Log_$logger.cannotSelectRandomMembers(int numNeeded, List<Address> members)
void	Log.cannotSelectRandomMembers(int numNeeded, List<Address> members)
void	Log_$logger.expectedJustOneResponse(Map<Address,Response> lr)
void	Log.expectedJustOneResponse(Map<Address,Response> lr)
CacheJoinException	Log_$logger.extraneousMembersJoinRestoredCache(List<Address> extraneousMembers, String cacheName)
CacheJoinException	Log.extraneousMembersJoinRestoredCache(List<Address> extraneousMembers, String cacheName)
void	Log_$logger.ignoringCacheTopology(Collection<Address> sender, CacheTopology topology)
void	Log.ignoringCacheTopology(Collection<Address> sender, CacheTopology topology)
void	Log_$logger.localAndPhysicalAddress(String cluster, Address address, List<Address> physicalAddresses)
void	Log.localAndPhysicalAddress(String cluster, Address address, List<Address> physicalAddresses)

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	XSiteStateTransferCollector.confirmStateTransfer(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	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>	XSiteStateProvider.getSitesMissingCoordinator(Collection<Address> currentMembers)
Collection<String>	XSiteStateProviderImpl.getSitesMissingCoordinator(Collection<Address> currentMembers)
boolean	XSiteStateTransferCollector.updateMembers(Collection<Address> members)

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

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

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