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

Packages that use Address

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

Uses of Address in org.infinispan.affinity

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

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

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

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

Uses of Address in org.infinispan.affinity.impl

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

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

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

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

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

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

Uses of Address in org.infinispan.commands

Fields in org.infinispan.commands declared as Address

Modifier and Type	Field	Description
protected Address	AbstractFlagAffectedCommand.origin

Methods in org.infinispan.commands that return Address

Modifier and Type	Method	Description
Address	CommandInvocationId.getAddress()
Address	AbstractFlagAffectedCommand.getOrigin()
Address	RequestUUID.toAddress()	Returns an Address representing the origin of this request within the cluster.

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

Modifier and Type	Method	Description
org.infinispan.commands.write.InvalidateCommand	CommandsFactory.buildInvalidateFromL1Command(Address origin, long flagsBitSet, Collection<Object> keys)
org.infinispan.commands.write.InvalidateCommand	CommandsFactoryImpl.buildInvalidateFromL1Command(Address origin, long flagsBitSet, Collection<Object> keys)
static CommandInvocationId	CommandInvocationId.generateId(Address address)
static RequestUUID	RequestUUID.of(Address address, long requestId)	Creates a RequestUUID for the specified node Address and request ID.
void	AbstractFlagAffectedCommand.setOrigin(Address origin)
default void	ReplicableCommand.setOrigin(Address origin)	Sets the sender's Address.

Uses of Address in org.infinispan.conflict

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

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

Uses of Address in org.infinispan.container.entries

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

Modifier and Type	Method	Description
Address	RemoteMetadata.getAddress()

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

Modifier	Constructor	Description
	RemoteMetadata(Address address, EntryVersion version)

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

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

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

Uses of Address in org.infinispan.context

Methods in org.infinispan.context that return Address

Modifier and Type	Method	Description
Address	InvocationContext.getOrigin()

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

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

Uses of Address in org.infinispan.context.impl

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

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

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

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

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

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

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

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

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

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

Uses of Address in org.infinispan.distribution

Methods in org.infinispan.distribution that return Address

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

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

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

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

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

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

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

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

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

Uses of Address in org.infinispan.distribution.ch

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

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

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

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

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

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

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

Modifier and Type	Method	Description
default void	ConsistentHash.toScopedState(ScopedPersistentState state, Function<Address,UUID> addressMapper)	Writes this ConsistentHash to the specified scoped persistent state.

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

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

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

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

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

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

Modifier and Type	Method	Description
List<Address>	DefaultConsistentHashFactory.Builder.getBackupOwners(int segment)
Map<Address,Float>	AbstractConsistentHash.getCapacityFactors()
Map<Address,Float>	ReplicatedConsistentHash.getCapacityFactors()
static HashMap<Address,Integer>	AbstractConsistentHash.getMemberIndexMap(List<Address> members)
List<Address>	AbstractConsistentHash.getMembers()
List<Address>	ReplicatedConsistentHash.getMembers()
List<Address>	DefaultConsistentHashFactory.Builder.getOwners(int segment)
List<Address>	DefaultConsistentHash.locateOwnersForSegment(int segmentId)
List<Address>	ReplicatedConsistentHash.locateOwnersForSegment(int segmentId)
protected Map<Address,Float>	AbstractConsistentHash.unionCapacityFactors(AbstractConsistentHash ch2)

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

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

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

Modifier and Type	Method	Description
boolean	DefaultConsistentHashFactory.Builder.addOwners(int segment, Collection<Address> newOwners)
protected void	AbstractConsistentHashFactory.checkCapacityFactors(List<Address> members, Map<Address,Float> capacityFactors)
protected void	AbstractConsistentHashFactory.checkCapacityFactors(List<Address> members, Map<Address,Float> capacityFactors)
int	DefaultConsistentHashFactory.Builder.computeActualNumOwners(int numOwners, List<Address> members, Map<Address,Float> capacityFactors)
int	DefaultConsistentHashFactory.Builder.computeActualNumOwners(int numOwners, List<Address> members, Map<Address,Float> capacityFactors)
CH	ConsistentHashFactory.create(int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)	Create a new consistent hash instance.
CH	ConsistentHashFactory.create(int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)	Create a new consistent hash instance.
static DefaultConsistentHash	DefaultConsistentHash.create(int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors, List<Address>[] segmentOwners)
static DefaultConsistentHash	DefaultConsistentHash.create(int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors, List<Address>[] segmentOwners)
DefaultConsistentHash	DefaultConsistentHashFactory.create(int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
DefaultConsistentHash	DefaultConsistentHashFactory.create(int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
ReplicatedConsistentHash	ReplicatedConsistentHashFactory.create(int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
ReplicatedConsistentHash	ReplicatedConsistentHashFactory.create(int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
DefaultConsistentHash	SyncConsistentHashFactory.create(int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
DefaultConsistentHash	SyncConsistentHashFactory.create(int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
ReplicatedConsistentHash	SyncReplicatedConsistentHashFactory.create(int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
ReplicatedConsistentHash	SyncReplicatedConsistentHashFactory.create(int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
protected TopologyAwareSyncConsistentHashFactory.Builder	TopologyAwareSyncConsistentHashFactory.createBuilder(int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
protected TopologyAwareSyncConsistentHashFactory.Builder	TopologyAwareSyncConsistentHashFactory.createBuilder(int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
protected Address	DefaultConsistentHashFactory.findNewBackupOwner(DefaultConsistentHashFactory.Builder builder, Collection<Address> excludes, Address owner)
protected Address	AbstractConsistentHashFactory.findNewPrimaryOwner(org.infinispan.distribution.ch.impl.AbstractConsistentHashFactory.Builder builder, Collection<Address> candidates, Address primaryOwner)
protected Address	AbstractConsistentHashFactory.findWorstPrimaryOwner(org.infinispan.distribution.ch.impl.AbstractConsistentHashFactory.Builder builder, List<Address> nodes)
default PersistedConsistentHash<CH>	ConsistentHashFactory.fromPersistentState(ScopedPersistentState state, Function<UUID,Address> addressMapper)	Recreates a ConsistentHash from a previously stored persistent state.
PersistedConsistentHash<DefaultConsistentHash>	DefaultConsistentHashFactory.fromPersistentState(ScopedPersistentState state, Function<UUID,Address> addressMapper)
PersistedConsistentHash<ReplicatedConsistentHash>	ReplicatedConsistentHashFactory.fromPersistentState(ScopedPersistentState state, Function<UUID,Address> addressMapper)
PersistedConsistentHash<DefaultConsistentHash>	SyncConsistentHashFactory.fromPersistentState(ScopedPersistentState state, Function<UUID,Address> addressMapper)
PersistedConsistentHash<ReplicatedConsistentHash>	SyncReplicatedConsistentHashFactory.fromPersistentState(ScopedPersistentState state, Function<UUID,Address> addressMapper)
static HashMap<Address,Integer>	AbstractConsistentHash.getMemberIndexMap(List<Address> members)
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.
protected static org.infinispan.distribution.ch.impl.PersistedMembers	AbstractConsistentHash.parseMembers(ScopedPersistentState state, Function<UUID,Address> addressMapper)
void	AbstractConsistentHash.toScopedState(ScopedPersistentState state, Function<Address,UUID> addressMapper)
void	DefaultConsistentHash.toScopedState(ScopedPersistentState state, Function<Address,UUID> addressMapper)
void	ReplicatedConsistentHash.toScopedState(ScopedPersistentState state, Function<Address,UUID> addressMapper)
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.
DefaultConsistentHash	DefaultConsistentHashFactory.updateMembers(DefaultConsistentHash baseCH, List<Address> actualMembers, Map<Address,Float> actualCapacityFactors)	Leavers are removed and segments without owners are assigned new owners.
DefaultConsistentHash	DefaultConsistentHashFactory.updateMembers(DefaultConsistentHash baseCH, List<Address> actualMembers, Map<Address,Float> actualCapacityFactors)	Leavers are removed and segments without owners are assigned new owners.
ReplicatedConsistentHash	ReplicatedConsistentHashFactory.updateMembers(ReplicatedConsistentHash baseCH, List<Address> newMembers, Map<Address,Float> actualCapacityFactors)
ReplicatedConsistentHash	ReplicatedConsistentHashFactory.updateMembers(ReplicatedConsistentHash baseCH, List<Address> newMembers, Map<Address,Float> actualCapacityFactors)
DefaultConsistentHash	SyncConsistentHashFactory.updateMembers(DefaultConsistentHash baseCH, List<Address> newMembers, Map<Address,Float> actualCapacityFactors)
DefaultConsistentHash	SyncConsistentHashFactory.updateMembers(DefaultConsistentHash baseCH, List<Address> newMembers, Map<Address,Float> actualCapacityFactors)
ReplicatedConsistentHash	SyncReplicatedConsistentHashFactory.updateMembers(ReplicatedConsistentHash baseCH, List<Address> newMembers, Map<Address,Float> actualCapacityFactors)
ReplicatedConsistentHash	SyncReplicatedConsistentHashFactory.updateMembers(ReplicatedConsistentHash baseCH, List<Address> newMembers, Map<Address,Float> actualCapacityFactors)
protected static void	AbstractConsistentHash.writeAddressToState(ScopedPersistentState state, List<Address> members, String sizeKey, String memberKeyFormat, Function<Address,UUID> addressMapper)
protected static void	AbstractConsistentHash.writeAddressToState(ScopedPersistentState state, List<Address> members, String sizeKey, String memberKeyFormat, Function<Address,UUID> addressMapper)

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

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

Uses of Address in org.infinispan.distribution.impl

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

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

Uses of Address in org.infinispan.distribution.topologyaware

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

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

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

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

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

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

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

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

Uses of Address in org.infinispan.manager

Methods in org.infinispan.manager that return Address

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

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

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

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

Modifier and Type	Method	Description
abstract boolean	ClusterExecutionPolicy.include(Address thisAddress, Address otherAddress)

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

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

Uses of Address in org.infinispan.manager.impl

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

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

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

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

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

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

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

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

Modifier and Type	Method	Description
Address	RemoteClusterListener.getOwnerAddress()

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

Uses of Address in org.infinispan.notifications.cachemanagerlistener

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

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

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

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

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

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

Modifier and Type	Method	Description
Address	ViewChangedEvent.getLocalAddress()

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

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

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

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

Modifier and Type	Method	Description
Address	EventImpl.getLocalAddress()

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

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

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

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

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

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

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

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

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

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

Uses of Address in org.infinispan.partitionhandling.impl

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

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

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

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

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

Modifier and Type	Method	Description
boolean	AvailablePartitionHandlingManager.addPartialCommit1PCTransaction(GlobalTransaction globalTransaction, Collection<Address> affectedNodes, Collection<Object> lockedKeys, List<org.infinispan.commands.write.WriteCommand> modifications)
boolean	PartitionHandlingManager.addPartialCommit1PCTransaction(GlobalTransaction globalTransaction, Collection<Address> affectedNodes, Collection<Object> lockedKeys, List<org.infinispan.commands.write.WriteCommand> modifications)	Adds a partially committed transaction.
boolean	PartitionHandlingManagerImpl.addPartialCommit1PCTransaction(GlobalTransaction globalTransaction, Collection<Address> affectedNodes, Collection<Object> lockedKeys, List<org.infinispan.commands.write.WriteCommand> modifications)
boolean	AvailablePartitionHandlingManager.addPartialCommit2PCTransaction(GlobalTransaction globalTransaction, Collection<Address> affectedNodes, Collection<Object> lockedKeys, Map<Object, IncrementableEntryVersion> newVersions)
boolean	PartitionHandlingManager.addPartialCommit2PCTransaction(GlobalTransaction globalTransaction, Collection<Address> affectedNodes, Collection<Object> lockedKeys, Map<Object, IncrementableEntryVersion> newVersions)	Adds a partially committed transaction.
boolean	PartitionHandlingManagerImpl.addPartialCommit2PCTransaction(GlobalTransaction globalTransaction, Collection<Address> affectedNodes, Collection<Object> lockedKeys, Map<Object, IncrementableEntryVersion> newVersions)
boolean	AvailablePartitionHandlingManager.addPartialRollbackTransaction(GlobalTransaction globalTransaction, Collection<Address> affectedNodes, Collection<Object> lockedKeys)
boolean	PartitionHandlingManager.addPartialRollbackTransaction(GlobalTransaction globalTransaction, Collection<Address> affectedNodes, Collection<Object> lockedKeys)	Adds a partially aborted transaction.
boolean	PartitionHandlingManagerImpl.addPartialRollbackTransaction(GlobalTransaction globalTransaction, Collection<Address> affectedNodes, Collection<Object> lockedKeys)
ConsistentHash	AvailabilityStrategyContext.calculateConflictHash(ConsistentHash preferredHash, Set<ConsistentHash> distinctHashes, List<Address> actualMembers)
CacheTopology	PreferAvailabilityStrategy.computePreferredTopology(Map<Address, CacheStatusResponse> statusResponseMap)	Ignore the AvailabilityStrategyContext and only compute the preferred topology for testing.
static boolean	AvailabilityStrategy.isDataLost(ConsistentHash consistentHash, Collection<Address> members)	Checks that all segments have, at least, one owner online to ensure data availability.
static <T> boolean	AvailabilityStrategy.isDataLost(ConsistentHash consistentHash, Collection<T> members, Function<Address,T> addressMapper)	Checks that all segments have, at least, one owner online to ensure data availability.
void	AvailabilityStrategyContext.manuallyUpdateAvailabilityMode(List<Address> actualMembers, AvailabilityMode mode, boolean cancelRebalance)	Enter a new availability mode manually.
void	AvailabilityStrategy.onClusterViewChange(AvailabilityStrategyContext context, List<Address> clusterMembers)	Called when the cluster view changed (e.g. because one or more nodes left abruptly).
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 AvailabilityStrategyContext.updateTopologiesAfterMerge(CacheTopology, CacheTopology, AvailabilityMode)
void	AvailabilityStrategyContext.queueRebalance(List<Address> newMembers)	Queue (or start) a rebalance.
boolean	AvailabilityStrategyContext.restartConflictResolution(List<Address> newMembers)	If CR is in progress, then this method cancels the current CR and starts a new CR phase with an updated topology based upon newMembers and the previously queued CR topology
void	AvailabilityStrategyContext.updateAvailabilityMode(List<Address> actualMembers, AvailabilityMode mode, boolean cancelRebalance)	Enter a new availability mode.
void	AvailabilityStrategyContext.updateCurrentTopology(List<Address> newMembers)	Use the configured ConsistentHashFactory to create a new CH with the given members, but do not start a rebalance.

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

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

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

Uses of Address in org.infinispan.remoting.responses

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

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

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

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

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

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

Uses of Address in org.infinispan.remoting.rpc

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

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

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

Modifier and Type	Method	Description
List<Address>	RpcManager.getMembers()	Returns members of a cluster scoped to the cache owning this RpcManager.
List<Address>	RpcManagerImpl.getMembers()

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

Modifier and Type	Method	Description
<T> CompletionStage<T>	RpcManager.invokeCommand(Address target, org.infinispan.commands.remote.CacheRpcCommand command, ResponseCollector<Address,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, org.infinispan.commands.remote.CacheRpcCommand command, ResponseCollector<Address,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, org.infinispan.commands.remote.CacheRpcCommand command, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder)	Asynchronously sends the ReplicableCommand to the destination using the specified DeliverOrder.
void	RpcManagerImpl.sendTo(Address destination, org.infinispan.commands.remote.CacheRpcCommand command, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder)

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

Modifier and Type	Method	Description
<T> CompletionStage<T>	RpcManager.invokeCommand(Collection<Address> targets, org.infinispan.commands.remote.CacheRpcCommand command, ResponseCollector<Address,T> collector, RpcOptions rpcOptions)	Invoke a command on a collection of node and pass the responses to a ResponseCollector.
<T> CompletionStage<T>	RpcManager.invokeCommand(Collection<Address> targets, org.infinispan.commands.remote.CacheRpcCommand command, ResponseCollector<Address,T> collector, RpcOptions rpcOptions)	Invoke a command on a collection of node and pass the responses to a ResponseCollector.
<T> CompletionStage<T>	RpcManager.invokeCommand(Address target, org.infinispan.commands.remote.CacheRpcCommand command, ResponseCollector<Address,T> collector, RpcOptions rpcOptions)	Invoke a command on a single node and pass the response to a ResponseCollector.
<T> CompletionStage<T>	RpcManagerImpl.invokeCommand(Collection<Address> targets, org.infinispan.commands.remote.CacheRpcCommand command, ResponseCollector<Address,T> collector, RpcOptions rpcOptions)
<T> CompletionStage<T>	RpcManagerImpl.invokeCommand(Collection<Address> targets, org.infinispan.commands.remote.CacheRpcCommand command, ResponseCollector<Address,T> collector, RpcOptions rpcOptions)
<T> CompletionStage<T>	RpcManagerImpl.invokeCommand(Address target, org.infinispan.commands.remote.CacheRpcCommand command, ResponseCollector<Address,T> collector, RpcOptions rpcOptions)
<T> CompletionStage<T>	RpcManager.invokeCommandOnAll(org.infinispan.commands.remote.CacheRpcCommand command, ResponseCollector<Address,T> collector, RpcOptions rpcOptions)	Invoke a command on all the nodes in the cluster and pass the responses to a ResponseCollector.
<T> CompletionStage<T>	RpcManagerImpl.invokeCommandOnAll(org.infinispan.commands.remote.CacheRpcCommand command, ResponseCollector<Address,T> collector, RpcOptions rpcOptions)
<T> CompletionStage<T>	RpcManager.invokeCommands(Collection<Address> targets, Function<Address, org.infinispan.commands.remote.CacheRpcCommand> commandGenerator, ResponseCollector<Address,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, org.infinispan.commands.remote.CacheRpcCommand> commandGenerator, ResponseCollector<Address,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, org.infinispan.commands.remote.CacheRpcCommand> commandGenerator, ResponseCollector<Address,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, org.infinispan.commands.remote.CacheRpcCommand> commandGenerator, ResponseCollector<Address,T> collector, RpcOptions rpcOptions)
<T> CompletionStage<T>	RpcManagerImpl.invokeCommands(Collection<Address> targets, Function<Address, org.infinispan.commands.remote.CacheRpcCommand> commandGenerator, ResponseCollector<Address,T> collector, RpcOptions rpcOptions)
<T> CompletionStage<T>	RpcManagerImpl.invokeCommands(Collection<Address> targets, Function<Address, org.infinispan.commands.remote.CacheRpcCommand> commandGenerator, ResponseCollector<Address,T> collector, RpcOptions rpcOptions)
<T> CompletionStage<T>	RpcManager.invokeCommandStaggered(Collection<Address> targets, org.infinispan.commands.remote.CacheRpcCommand command, ResponseCollector<Address,T> collector, RpcOptions rpcOptions)	Invoke a command on a collection of nodes and pass the responses to a ResponseCollector.
<T> CompletionStage<T>	RpcManager.invokeCommandStaggered(Collection<Address> targets, org.infinispan.commands.remote.CacheRpcCommand command, ResponseCollector<Address,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, org.infinispan.commands.remote.CacheRpcCommand command, ResponseCollector<Address,T> collector, RpcOptions rpcOptions)
<T> CompletionStage<T>	RpcManagerImpl.invokeCommandStaggered(Collection<Address> targets, org.infinispan.commands.remote.CacheRpcCommand command, ResponseCollector<Address,T> collector, RpcOptions rpcOptions)
void	RpcManager.sendToMany(Collection<Address> destinations, org.infinispan.commands.remote.CacheRpcCommand command, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder)	Asynchronously sends the ReplicableCommand to the set of destination using the specified DeliverOrder.
void	RpcManagerImpl.sendToMany(Collection<Address> destinations, org.infinispan.commands.remote.CacheRpcCommand command, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder)

Uses of Address in org.infinispan.remoting.transport

Classes in org.infinispan.remoting.transport that implement interfaces with type arguments of type Address

Modifier and Type	Class	Description
class	Address	An encapsulation of a JGroups ExtendedUUID with a NodeVersion, site id, rack id, and a machine id.
final class	Address$___Marshaller_4f32fa50926d8770f1ad6f353f6c769a25846818788604d769c7e3c601cdac10	WARNING: Generated code!
class	ValidResponseCollector<T>	Base class for response collectors, splitting responses into valid responses, exception responses, and target missing.

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

Modifier and Type	Field	Description
static final Address	Address.LOCAL

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

Modifier and Type	Method	Description
static Address	Address.fromExtendedUUID(org.jgroups.util.ExtendedUUID address)
static Address	Address.fromNodeUUID(UUID nodeUUID)
Address	AbstractDelegatingTransport.getAddress()
Address	Transport.getAddress()	Retrieves the current cache instance's network address
Address	AbstractDelegatingTransport.getCoordinator()
Address	Transport.getCoordinator()
static Address	Address.protoFactory(long mostSignificantBits, long leastSignificantBits, NodeVersion version, String siteId, String rackId, String machineId)
static Address	Address.random()
static Address	Address.random(String name)
static Address	Address.random(String name, String siteId, String rackId, String machineId)
Address	Address$___Marshaller_4f32fa50926d8770f1ad6f353f6c769a25846818788604d769c7e3c601cdac10.read(org.infinispan.protostream.ProtobufTagMarshaller.ReadContext $1)

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

Modifier and Type	Method	Description
Class<Address>	Address$___Marshaller_4f32fa50926d8770f1ad6f353f6c769a25846818788604d769c7e3c601cdac10.getJavaClass()
List<Address>	AbstractDelegatingTransport.getMembers()
List<Address>	Transport.getMembers()	Returns a list of members in the current cluster view.
Collection<Address>	AbstractDelegatingTransport.getRelayNodesAddress()
Collection<Address>	Transport.getRelayNodesAddress()
CompletableFuture<Map<Address,Response>>	AbstractDelegatingTransport.invokeRemotelyAsync(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, ResponseFilter responseFilter, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder)
CompletableFuture<Map<Address,Response>>	Transport.invokeRemotelyAsync(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, ResponseFilter responseFilter, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder)
default CompletableFuture<Map<Address,Response>>	Transport.invokeRemotelyAsync(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, ResponseFilter responseFilter, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, boolean anycast)	Deprecated, for removal: This API element is subject to removal in a future version. Use Transport.invokeRemotelyAsync(Collection, ReplicableCommand, ResponseMode, long, ResponseFilter, DeliverOrder).

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.
final T	ValidResponseCollector.addResponse(Address sender, Response response)
protected abstract T	ValidResponseCollector.addTargetNotFound(Address sender)	Process a target leaving the cluster or stopping the cache.
protected abstract T	ValidResponseCollector.addValidResponse(Address sender, ValidResponse<?> response)	Process a valid response from a target.
int	Address.compareTo(Address other)
<T> CompletionStage<T>	AbstractDelegatingTransport.invokeCommand(Address target, ReplicableCommand command, ResponseCollector<Address,T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit)
default <T> CompletionStage<T>	Transport.invokeCommand(Address target, ReplicableCommand command, ResponseCollector<Address,T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit)	Invoke a command on a single node and pass the response to a ResponseCollector.
boolean	Address.isSameMachine(Address other)
boolean	Address.isSameRack(Address other)
boolean	Address.isSameSite(Address other)
void	AbstractDelegatingTransport.sendTo(Address destination, ReplicableCommand rpcCommand, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder)
void	Transport.sendTo(Address destination, ReplicableCommand rpcCommand, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder)	Asynchronously sends the ReplicableCommand to the destination using the specified DeliverOrder.
static org.jgroups.util.ExtendedUUID	Address.toExtendedUUID(Address address)
void	Address$___Marshaller_4f32fa50926d8770f1ad6f353f6c769a25846818788604d769c7e3c601cdac10.write(org.infinispan.protostream.ProtobufTagMarshaller.WriteContext $1, Address $2)

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

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

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

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

Modifier and Type	Class	Description
class	ExclusiveTargetRequest<T>	Request implementation that waits for responses from multiple target nodes.
class	FilterMapResponseCollector	Response collector supporting JGroupsTransport.invokeRemotelyAsync(Collection, ReplicableCommand, ResponseMode, long, ResponseFilter, DeliverOrder).
class	MapResponseCollector	Response collector supporting JGroupsTransport.invokeRemotelyAsync(Collection, ReplicableCommand, ResponseMode, long, ResponseFilter, DeliverOrder).
class	SingleTargetRequest<T>	Request implementation that waits for a response from a single target node.
class	SingletonMapResponseCollector	Response collector supporting JGroupsTransport.invokeRemotelyAsync(Collection, ReplicableCommand, ResponseMode, long, ResponseFilter, DeliverOrder).
class	SingletonMapResponseCollector	Response collector supporting JGroupsTransport.invokeRemotelyAsync(Collection, ReplicableCommand, ResponseMode, long, ResponseFilter, DeliverOrder).

Classes in org.infinispan.remoting.transport.impl that implement interfaces with type arguments of type Address

Modifier and Type	Class	Description
class	PassthroughMapResponseCollector	Receive responses from multiple nodes, without checking that the responses are valid.
class	PassthroughMapResponseCollector	Receive responses from multiple nodes, without checking that the responses are valid.
class	PassthroughSingleResponseCollector	RPC to a single node, without any validity checks.

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

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

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

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

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

Modifier and Type	Method	Description
protected abstract void	ExclusiveTargetRequest.actualOnResponse(Address sender, Response response)
protected void	MultiTargetRequest.actualOnResponse(Address sender, Response response)
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)
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)
final void	ExclusiveTargetRequest.onResponse(Address sender, Response response)
void	SingleTargetRequest.onResponse(Address sender, Response response)
protected Map<Address,Response>	SingletonMapResponseCollector.targetNotFound(Address sender)
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
protected abstract boolean	ExclusiveTargetRequest.actualOnView(Set<Address> members)
protected boolean	MultiTargetRequest.actualOnView(Set<Address> members)
final boolean	ExclusiveTargetRequest.onNewView(Set<Address> members)
boolean	Request.onNewView(Set<Address> members)	Called when the node received a new cluster view.
boolean	SingleTargetRequest.onNewView(Set<Address> members)

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

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

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

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

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

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

Modifier and Type	Field	Description
protected Address	JGroupsTransport.address

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

Modifier and Type	Method	Description
Address	RequestTracker.destination()
static Address	AddressCache.fromExtendedUUID(org.jgroups.util.ExtendedUUID addr)
Address	JGroupsTransport.getAddress()
Address	ClusterView.getCoordinator()
Address	JGroupsTransport.getCoordinator()
static Address	AddressCache.getIfPresent(long mostSignificantBits, long leastSignificantBits)
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()
Collection<Address>	JGroupsTransport.getRelayNodesAddress()
CompletableFuture<Map<Address,Response>>	JGroupsTransport.invokeRemotelyAsync(Collection<Address> recipients, ReplicableCommand command, ResponseMode mode, long timeout, ResponseFilter responseFilter, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder)

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

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

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

Modifier and Type	Method	Description
<T> CompletionStage<T>	JGroupsTransport.invokeCommand(Collection<Address> targets, ReplicableCommand command, ResponseCollector<Address,T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit)
<T> CompletionStage<T>	JGroupsTransport.invokeCommand(Collection<Address> targets, ReplicableCommand command, ResponseCollector<Address,T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit)
<T> CompletionStage<T>	JGroupsTransport.invokeCommand(Address target, ReplicableCommand command, ResponseCollector<Address,T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit)
<T> CompletionStage<T>	JGroupsTransport.invokeCommandOnAll(Collection<Address> requiredTargets, ReplicableCommand command, ResponseCollector<Address,T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit)
<T> CompletionStage<T>	JGroupsTransport.invokeCommandOnAll(Collection<Address> requiredTargets, ReplicableCommand command, ResponseCollector<Address,T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit)
<T> CompletionStage<T>	JGroupsTransport.invokeCommandOnAll(ReplicableCommand command, ResponseCollector<Address,T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit)
<T> CompletionStage<T>	JGroupsTransport.invokeCommands(Collection<Address> targets, Function<Address, ReplicableCommand> commandGenerator, ResponseCollector<Address,T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit timeUnit)
<T> CompletionStage<T>	JGroupsTransport.invokeCommands(Collection<Address> targets, Function<Address, ReplicableCommand> commandGenerator, ResponseCollector<Address,T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit timeUnit)
<T> CompletionStage<T>	JGroupsTransport.invokeCommands(Collection<Address> targets, Function<Address, ReplicableCommand> commandGenerator, ResponseCollector<Address,T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit timeUnit)
<T> CompletionStage<T>	JGroupsTransport.invokeCommandStaggered(Collection<Address> targets, ReplicableCommand command, ResponseCollector<Address,T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit)
<T> CompletionStage<T>	JGroupsTransport.invokeCommandStaggered(Collection<Address> targets, ReplicableCommand command, ResponseCollector<Address,T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit)
CompletableFuture<Map<Address,Response>>	JGroupsTransport.invokeRemotelyAsync(Collection<Address> recipients, ReplicableCommand command, ResponseMode mode, long timeout, ResponseFilter responseFilter, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder)
boolean	SingleSiteRequest.onNewView(Set<Address> members)
void	JGroupsTransport.sendToMany(Collection<Address> targets, ReplicableCommand command, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder)

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

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

Uses of Address in org.infinispan.server.hotrod

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

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

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

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

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

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

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

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

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

Modifier and Type	Method	Description
Address	TxState.getOriginator()

Uses of Address in org.infinispan.stream.impl

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

Modifier and Type	Field	Description
protected final Address	AbstractCacheStream.localAddress

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

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

Uses of Address in org.infinispan.topology

Methods in org.infinispan.topology that return Address

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

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

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

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

Modifier and Type	Method	Description
void	PersistentUUIDManager.addPersistentAddressMapping(Address address, UUID persistentUUID)	Adds a mapping between an Address and a UUID
void	PersistentUUIDManagerImpl.addPersistentAddressMapping(Address address, UUID persistentUUID)
void	ClusterCacheStatus.confirmRebalancePhase(Address member, int receivedTopologyId)
CacheStatusResponse	ClusterCacheStatus.doJoin(Address joiner, CacheJoinInfo joinInfo)
CompletionStage<Void>	ClusterCacheStatus.doLeave(Address leaver)
UUID	PersistentUUIDManager.getPersistentUuid(Address address)	Retrieves the UUID of a node given its Address
UUID	PersistentUUIDManagerImpl.getPersistentUuid(Address address)
CompletionStage<CacheStatusResponse>	ClusterTopologyManager.handleJoin(String cacheName, Address joiner, CacheJoinInfo joinInfo, int viewId)	Signals that a new member is joining the cache.
CompletionStage<CacheStatusResponse>	ClusterTopologyManagerImpl.handleJoin(String cacheName, Address joiner, CacheJoinInfo joinInfo, int joinerViewId)
CompletionStage<Void>	ClusterTopologyManager.handleLeave(String cacheName, Address leaver)	Signals that a member is leaving the cache.
default CompletionStage<Void>	ClusterTopologyManager.handleLeave(String cacheName, Address leaver, int viewId)	Deprecated, for removal: This API element is subject to removal in a future version. since 16.0, use ClusterTopologyManager.handleLeave(String, Address) instead
CompletionStage<Void>	ClusterTopologyManagerImpl.handleLeave(String cacheName, Address leaver)
CompletionStage<Void>	LocalTopologyManager.handleRebalance(String cacheName, CacheTopology cacheTopology, int viewId, Address sender)	Performs the state transfer.
CompletionStage<Void>	LocalTopologyManagerImpl.handleRebalance(String cacheName, CacheTopology cacheTopology, int viewId, Address sender)
CompletionStage<Void>	ClusterTopologyManager.handleRebalancePhaseConfirm(String cacheName, Address node, int topologyId, Throwable throwable)
default CompletionStage<Void>	ClusterTopologyManager.handleRebalancePhaseConfirm(String cacheName, Address node, int topologyId, Throwable throwable, int viewId)	Deprecated, for removal: This API element is subject to removal in a future version. since 16.0, use ClusterTopologyManager.handleRebalancePhaseConfirm(String, Address, int, Throwable) instead
CompletionStage<Void>	ClusterTopologyManagerImpl.handleRebalancePhaseConfirm(String cacheName, Address node, int topologyId, Throwable throwable)
CompletionStage<Void>	LocalTopologyManager.handleStableTopologyUpdate(String cacheName, CacheTopology cacheTopology, Address sender, int viewId)	Update the stable cache topology.
CompletionStage<Void>	LocalTopologyManagerImpl.handleStableTopologyUpdate(String cacheName, CacheTopology newStableTopology, Address sender, int viewId)
CompletionStage<Void>	LocalTopologyManager.handleTopologyUpdate(String cacheName, CacheTopology cacheTopology, AvailabilityMode availabilityMode, int viewId, Address sender)	Updates the current and/or pending consistent hash, without transferring any state.
CompletionStage<Void>	LocalTopologyManagerImpl.handleTopologyUpdate(String cacheName, CacheTopology cacheTopology, AvailabilityMode availabilityMode, int viewId, Address sender)
void	PersistentUUIDManager.removePersistentAddressMapping(Address address)	Removes any address mapping for the specified Address
void	PersistentUUIDManagerImpl.removePersistentAddressMapping(Address address)

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

Modifier and Type	Method	Description
ConsistentHash	ClusterCacheStatus.calculateConflictHash(ConsistentHash preferredHash, Set<ConsistentHash> distinctHashes, List<Address> actualMembers)
void	ClusterCacheStatus.doMergePartitions(Map<Address, CacheStatusResponse> statusResponses)
<T> CompletionStage<T>	TopologyManagementHelper.executeOnClusterSync(Transport transport, ReplicableCommand command, int timeout, ResponseCollector<Address,T> responseCollector)
void	ClusterCacheStatus.manuallyUpdateAvailabilityMode(List<Address> actualMembers, AvailabilityMode mode, boolean cancelRebalance)
List<UUID>	PersistentUUIDManager.mapAddresses(List<Address> addresses)	Returns a list of UUIDs for the supplied Addresses
List<UUID>	PersistentUUIDManagerImpl.mapAddresses(List<Address> addresses)
void	ClusterCacheStatus.queueConflictResolution(CacheTopology conflictTopology, Set<Address> preferredNodes)
void	ClusterCacheStatus.queueRebalance(List<Address> newMembers)
boolean	ClusterCacheStatus.restartConflictResolution(List<Address> members)
void	ClusterCacheStatus.updateAvailabilityMode(List<Address> actualMembers, AvailabilityMode newAvailabilityMode, boolean cancelRebalance)
void	ClusterCacheStatus.updateCurrentTopology(List<Address> newMembers)

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

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

Uses of Address in org.infinispan.transaction.impl

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

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

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

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

Uses of Address in org.infinispan.transaction.xa

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

Modifier and Type	Method	Description
Address	GlobalTransaction.getAddress()

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

Modifier and Type	Method	Description
GlobalTransaction	TransactionFactory.newGlobalTransaction(Address addr, boolean remote)
GlobalTransaction	TransactionFactory.newGlobalTransaction(Address addr, boolean remote, boolean client)
GlobalTransaction	TransactionFactory.TxFactoryEnum.newGlobalTransaction(Address addr, boolean remote, VersionGenerator clusterIdGenerator, boolean clustered)	Deprecated, for removal: This API element is subject to removal in a future version.
abstract GlobalTransaction	TransactionFactory.TxFactoryEnum.newGlobalTransaction(Address addr, boolean remote, VersionGenerator clusterIdGenerator, boolean clustered, boolean client)

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

Modifier	Constructor	Description
	GlobalTransaction(Address addr, boolean remote)
	GlobalTransaction(Address addr, boolean remote, boolean clientTx)

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

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

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

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

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

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

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

Uses of Address in org.infinispan.util.concurrent

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

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

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

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

Uses of Address in org.infinispan.util.logging

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

Modifier and Type	Method	Description
final void	Log_$logger.errorReadingRebalancingStatus(Address coordinator, Throwable t)
final void	Log_$logger.exceptionDuringClusterListenerRetrieval(Address address, Throwable cause)
final void	Log_$logger.failedToRequestSegments(String cacheName, Address source, Collection<Integer> segments, Throwable e)
final void	Log_$logger.failedToRetrieveTransactionsForSegments(String cacheName, Address source, Collection<Integer> segments, Throwable t)
final void	Log_$logger.failedToTransferTombstones(Address requestor, IntSet segments, Throwable t)
final void	Log_$logger.ignoringUnsolicitedState(Address node, int segment, String cacheName)
final TimeoutException	Log_$logger.initialStateTransferTimeout(String cacheName, Address localAddress)
final void	Log_$logger.localAndPhysicalAddress(String cluster, Address address, List<PhysicalAddress> physicalAddresses)
final CacheJoinException	Log_$logger.nodeWithIncompatibleStateJoiningCache(Address joiner, String cacheName)
final CacheJoinException	Log_$logger.nodeWithPersistentStateJoiningClusterWithoutState(Address joiner, String cacheName)
final void	Log_$logger.rebalanceError(String cacheName, Address node, int topologyId, Throwable cause)
final void	Log_$logger.rebalancePhaseConfirmedOnNode(CacheTopology.Phase phase, String cacheName, Address node, int topologyId)
final TimeoutException	Log_$logger.remoteNodeTimedOut(Address address, long time, TimeUnit unit)
final void	Log_$logger.unableToLockToInvalidate(Object key, Address address)
final IllegalArgumentException	Log_$logger.unexpectedResponse(Address target, Response response)
final void	Log_$logger.unsuccessfulResponseForClusterListeners(Address address, Response response)
final void	Log_$logger.unsuccessfulResponseRetrievingTransactionsForSegments(Address address, Response response)

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

Modifier and Type	Method	Description
final void	Log_$logger.expectedJustOneResponse(Map<Address,Response> lr)
final CacheJoinException	Log_$logger.extraneousMembersJoinRestoredCache(List<Address> extraneousMembers, String cacheName)
final void	Log_$logger.ignoringCacheTopology(Collection<Address> sender, CacheTopology topology)
final void	Log_$logger.recoverFromStateMissingMembers(String cacheName, List<Address> members, int total)
final MissingMembersException	Log_$logger.recoverFromStateMissingMembers(String cacheName, List<Address> members, String total)

Uses of Address in org.infinispan.xsite.irac

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

Modifier and Type	Method	Description
void	DefaultIracManager.checkStaleKeys(Address origin, Collection<IracManagerKeyInfo> keys)
void	IracManager.checkStaleKeys(Address origin, Collection<IracManagerKeyInfo> keys)	Checks a remote node's list of IracManagerKeyInfo for stale or outdated entries.
void	NoOpIracManager.checkStaleKeys(Address origin, Collection<IracManagerKeyInfo> keys)
void	DefaultIracManager.requestState(Address requestor, IntSet segments)
void	IracManager.requestState(Address requestor, IntSet segments)	Requests the state stored in this instance for the given segments.
void	NoOpIracManager.requestState(Address requestor, IntSet segments)

Uses of Address in org.infinispan.xsite.response

Classes in org.infinispan.xsite.response that implement interfaces with type arguments of type Address

Modifier and Type	Class	Description
class	AutoStateTransferResponseCollector	A ResponseCollector that merges AutoStateTransferResponse.

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

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

Uses of Address in org.infinispan.xsite.statetransfer

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

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

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

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

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

Modifier	Constructor	Description
	XSiteStateTransferCollector(Collection<Address> confirmationPending)

Uses of Address in org.infinispan.xsite.status

Subclasses with type arguments of type Address in org.infinispan.xsite.status

Modifier and Type	Class	Description
class	CacheMixedSiteStatus	A mixed SiteStatus.
class	CacheSiteStatusBuilder	A per-cache SiteStatus builder.

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

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

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

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

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

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