|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Address | |
---|---|
org.infinispan.affinity | |
org.infinispan.commands | Commands that operate on the cache, either locally or remotely. |
org.infinispan.commands.control | Commands that control and coordinate certain cache operations, such as rehashing, state transfer and locking. |
org.infinispan.context.impl | This package contains different context implementations, selected dynamically based on the type of invocation. |
org.infinispan.demo | Classes, programs and applications that help demonstrate how Infinispan can be used. |
org.infinispan.distribution | Classes relating to the distributed cache mode. |
org.infinispan.distribution.ch | |
org.infinispan.lucenedemo | |
org.infinispan.manager | Cache manager package |
org.infinispan.notifications.cachemanagerlistener | CacheManager -specific notifications and eventing. |
org.infinispan.notifications.cachemanagerlistener.event | |
org.infinispan.remoting | Remote communication between cache instances. |
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.jgroups | A transport implementation based on JGroups. |
org.infinispan.transaction.xa | XA transaction support. |
Uses of Address in org.infinispan.affinity |
---|
Methods in org.infinispan.affinity that return types with arguments of type Address | |
---|---|
Map<Address,BlockingQueue> |
KeyAffinityServiceImpl.getAddress2KeysMapping()
|
Methods in org.infinispan.affinity with parameters of type Address | |
---|---|
Object |
KeyAffinityServiceImpl.getKeyForAddress(Address address)
|
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 | ||
---|---|---|
static
|
KeyAffinityServiceFactory.newKeyAffinityService(Cache<K,V> cache,
Collection<Address> filter,
KeyGenerator 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
|
KeyAffinityServiceFactory.newKeyAffinityService(Cache<K,V> cache,
Collection<Address> filter,
KeyGenerator keyGenerator,
Executor ex,
int keyBufferSize,
boolean start)
Creates a service that would only generate keys for addresses specified in filter. |
Constructor parameters in org.infinispan.affinity with type arguments of type Address | |
---|---|
KeyAffinityServiceImpl(Executor executor,
Cache cache,
KeyGenerator keyGenerator,
int bufferSize,
Collection<Address> filter,
boolean start)
|
Uses of Address in org.infinispan.commands |
---|
Method parameters in org.infinispan.commands with type arguments of type Address | |
---|---|
RehashControlCommand |
CommandsFactoryImpl.buildRehashControlCommand(RehashControlCommand.Type type,
Address sender,
Map<Object,InternalCacheValue> state,
ConsistentHash oldCH,
ConsistentHash newCH,
List<Address> leavers)
|
RehashControlCommand |
CommandsFactory.buildRehashControlCommand(RehashControlCommand.Type subtype,
Address sender,
Map<Object,InternalCacheValue> state,
ConsistentHash oldCH,
ConsistentHash newCH,
List<Address> leaversHandled)
Builds a RehashControlCommand for coordinating a rehash event. |
Uses of Address in org.infinispan.commands.control |
---|
Constructors in org.infinispan.commands.control with parameters of type Address | |
---|---|
RehashControlCommand(String cacheName,
RehashControlCommand.Type type,
Address sender,
List<WriteCommand> txLogCommands,
List<PrepareCommand> pendingPrepares,
CommandsFactory commandsFactory)
|
|
RehashControlCommand(String cacheName,
RehashControlCommand.Type type,
Address sender,
Map<Object,InternalCacheValue> state,
ConsistentHash oldConsistentHash,
ConsistentHash consistentHash,
List<Address> leavers,
CommandsFactory commandsFactory)
|
Constructor parameters in org.infinispan.commands.control with type arguments of type Address | |
---|---|
RehashControlCommand(String cacheName,
RehashControlCommand.Type type,
Address sender,
Map<Object,InternalCacheValue> state,
ConsistentHash oldConsistentHash,
ConsistentHash consistentHash,
List<Address> leavers,
CommandsFactory commandsFactory)
|
Uses of Address in org.infinispan.context.impl |
---|
Methods in org.infinispan.context.impl that return types with arguments of type Address | |
---|---|
Collection<Address> |
LocalTxInvocationContext.getRemoteLocksAcquired()
|
Method parameters in org.infinispan.context.impl with type arguments of type Address | |
---|---|
void |
LocalTxInvocationContext.remoteLocksAcquired(Collection<Address> nodes)
|
Uses of Address in org.infinispan.demo |
---|
Method parameters in org.infinispan.demo with type arguments of type Address | |
---|---|
void |
InfinispanDemo.ClusterTableModel.setMembers(List<Address> m)
|
Uses of Address in org.infinispan.distribution |
---|
Fields in org.infinispan.distribution declared as Address | |
---|---|
protected Address |
RehashTask.self
|
Methods in org.infinispan.distribution that return Address | |
---|---|
Address |
JoinTask.getMyAddress()
|
Methods in org.infinispan.distribution that return types with arguments of type Address | |
---|---|
protected Collection<Address> |
RehashTask.coordinator()
|
List<Address> |
DistributionManagerImpl.getAffectedNodes(Set<Object> affectedKeys)
|
List<Address> |
DistributionManager.getAffectedNodes(Set<Object> affectedKeys)
A helper method that retrieves a list of nodes affected by operations on a set of keys. |
protected Collection<Address> |
RehashTask.getInvalidHolders(Object key,
ConsistentHash chOld,
ConsistentHash chNew)
|
List<Address> |
DistributionManagerImpl.getLeavers()
|
List<Address> |
DistributionManagerImpl.locate(Object key)
|
List<Address> |
DistributionManager.locate(Object key)
Locates a key in a cluster. |
Map<Object,List<Address>> |
DistributionManagerImpl.locateAll(Collection<Object> keys)
|
Map<Object,List<Address>> |
DistributionManager.locateAll(Collection<Object> keys)
Locates a list of keys in a cluster. |
Map<Object,List<Address>> |
DistributionManagerImpl.locateAll(Collection<Object> keys,
int numOwners)
|
Map<Object,List<Address>> |
DistributionManager.locateAll(Collection<Object> keys,
int numOwners)
Same as DistributionManager.locateAll(java.util.Collection) , but the list of addresses only contains numOwners owners. |
Set<Address> |
DistributionManagerImpl.requestPermissionToJoin(Address a)
|
Set<Address> |
DistributionManager.requestPermissionToJoin(Address joiner)
"Asks" a coordinator if a joiner may join. |
Methods in org.infinispan.distribution with parameters of type Address | |
---|---|
void |
DistributionManagerImpl.abortJoin(Address joiner)
|
void |
DistributionManager.abortJoin(Address sender)
|
List<WriteCommand> |
TransactionLoggerImpl.drainAndLock(Address lockedFor)
|
List<WriteCommand> |
RemoteTransactionLoggerImpl.drainAndLock(Address notUsed)
|
List<WriteCommand> |
RemoteTransactionLogger.drainAndLock(Address lockFor)
Similar to RemoteTransactionLogger.drain() except that relevant locks are acquired so that no more commands are added to the
transaction log during this process, and transaction logging is disabled after draining. |
NodeTopologyInfo |
DistributionManagerImpl.informRehashOnJoin(Address a,
boolean starting,
NodeTopologyInfo nodeTopologyInfo)
|
NodeTopologyInfo |
DistributionManager.informRehashOnJoin(Address joiner,
boolean starting,
NodeTopologyInfo nodeTopologyInfo)
This will cause all nodes to add the joiner to their consistent hash instance (usually by creating a UnionConsistentHash |
void |
DistributionManagerImpl.informRehashOnLeave(Address sender)
|
void |
DistributionManager.informRehashOnLeave(Address sender)
|
void |
DistributionManagerImpl.markLeaverAsHandled(Address leaver)
|
boolean |
DistributionManagerImpl.removeLeaver(Address leaver)
|
Set<Address> |
DistributionManagerImpl.requestPermissionToJoin(Address a)
|
Set<Address> |
DistributionManager.requestPermissionToJoin(Address joiner)
"Asks" a coordinator if a joiner may join. |
void |
TransactionLoggerImpl.unlockAndDisable(Address lockedFor)
|
void |
RemoteTransactionLoggerImpl.unlockAndDisable(Address notUsed)
|
void |
RemoteTransactionLogger.unlockAndDisable(Address lockedFor)
Unlocks and disables the transaction logger. |
Method parameters in org.infinispan.distribution with type arguments of type Address | |
---|---|
boolean |
DistributionManagerImpl.awaitLeaveRehashAcks(Set<Address> stateReceivers,
long timeout)
|
protected void |
RehashTask.invalidateInvalidHolders(List<Address> doNotInvalidate,
ConsistentHash chOld,
ConsistentHash chNew)
|
void |
DistributionManagerImpl.rehash(List<Address> newMembers,
List<Address> oldMembers)
|
void |
DistributionManagerImpl.rehash(List<Address> newMembers,
List<Address> oldMembers)
|
Constructors in org.infinispan.distribution with parameters of type Address | |
---|---|
InvertedLeaveTask.LeaveStateGrabber(Address stateProvider,
ReplicableCommand command,
ConsistentHash newConsistentHash)
|
|
JoinTask.JoinStateGrabber(Address stateProvider,
ReplicableCommand command,
ConsistentHash newConsistentHash)
|
|
RehashTask.StateGrabber(Address stateProvider,
ReplicableCommand command,
ConsistentHash newConsistentHash)
|
|
RemoteTransactionLoggerImpl(CommandsFactory commandsFactory,
Address targetNode,
RpcManager rpcManager)
|
Constructor parameters in org.infinispan.distribution with type arguments of type Address | |
---|---|
InvertedLeaveTask(DistributionManagerImpl dmi,
RpcManager rpcManager,
Configuration conf,
CommandsFactory commandsFactory,
DataContainer dataContainer,
List<Address> stateProviders,
List<Address> stateReceivers,
boolean isReceiver)
|
|
InvertedLeaveTask(DistributionManagerImpl dmi,
RpcManager rpcManager,
Configuration conf,
CommandsFactory commandsFactory,
DataContainer dataContainer,
List<Address> stateProviders,
List<Address> stateReceivers,
boolean isReceiver)
|
|
MergeTask(RpcManager rpcManager,
CommandsFactory commandsFactory,
Configuration conf,
DataContainer dataContainer,
DistributionManagerImpl dmi,
InboundInvocationHandler inboundInvocationHandler,
List<Address> newView,
List<List<Address>> mergedGroups)
|
|
MergeTask(RpcManager rpcManager,
CommandsFactory commandsFactory,
Configuration conf,
DataContainer dataContainer,
DistributionManagerImpl dmi,
InboundInvocationHandler inboundInvocationHandler,
List<Address> newView,
List<List<Address>> mergedGroups)
|
Uses of Address in org.infinispan.distribution.ch |
---|
Fields in org.infinispan.distribution.ch declared as Address | |
---|---|
Address |
ExperimentalDefaultConsistentHash.Entry.address
|
Fields in org.infinispan.distribution.ch with type parameters of type Address | |
---|---|
protected Map<Address,Integer> |
AbstractWheelConsistentHash.addressToHashIds
|
protected Set<Address> |
AbstractConsistentHash.caches
|
protected SortedMap<Integer,Address> |
AbstractWheelConsistentHash.positions
|
Methods in org.infinispan.distribution.ch that return Address | |
---|---|
Address |
NodeTopologyInfo.getAddress()
|
Methods in org.infinispan.distribution.ch that return types with arguments of type Address | |
---|---|
List<Address> |
UnionConsistentHash.getBackupsForNode(Address node,
int replCount)
|
List<Address> |
ExperimentalDefaultConsistentHash.getBackupsForNode(Address node,
int replCount)
|
List<Address> |
AbstractWheelConsistentHash.getBackupsForNode(Address node,
int replCount)
|
List<Address> |
ConsistentHash.getBackupsForNode(Address node,
int replCount)
Returns the nodes that backup data for the supplied node including the node itself. |
Set<Address> |
UnionConsistentHash.getCaches()
|
Set<Address> |
ExperimentalDefaultConsistentHash.getCaches()
|
Set<Address> |
AbstractConsistentHash.getCaches()
|
Set<Address> |
ConsistentHash.getCaches()
Should return a collection of cache addresses in the cluster. |
List<Address> |
DefaultConsistentHash.getStateProvidersOnJoin(Address self,
int replCount)
|
List<Address> |
UnionConsistentHash.getStateProvidersOnJoin(Address joiner,
int replCount)
|
List<Address> |
TopologyAwareConsistentHash.getStateProvidersOnJoin(Address joiner,
int replCount)
In this situation are the same nodes providing state on join as the nodes that provide state on leave. |
List<Address> |
ExperimentalDefaultConsistentHash.getStateProvidersOnJoin(Address joiner,
int replCount)
|
List<Address> |
ConsistentHash.getStateProvidersOnJoin(Address joiner,
int replCount)
Returns the nodes that would act as state providers when a new node joins: - the nodes for which the joiner is a backup - the nodes that held joiner's state |
List<Address> |
DefaultConsistentHash.getStateProvidersOnLeave(Address leaver,
int replCount)
|
List<Address> |
UnionConsistentHash.getStateProvidersOnLeave(Address leaver,
int replCount)
|
List<Address> |
TopologyAwareConsistentHash.getStateProvidersOnLeave(Address leaver,
int replCount)
|
List<Address> |
ExperimentalDefaultConsistentHash.getStateProvidersOnLeave(Address leaver,
int replCount)
|
List<Address> |
ConsistentHash.getStateProvidersOnLeave(Address leaver,
int replCount)
Returns the nodes that need will replicate their state if the specified node crashes. |
List<Address> |
DefaultConsistentHash.locate(Object key,
int replCount)
|
List<Address> |
UnionConsistentHash.locate(Object key,
int replCount)
|
List<Address> |
TopologyAwareConsistentHash.locate(Object key,
int replCount)
|
List<Address> |
ExperimentalDefaultConsistentHash.locate(Object key,
int replCount)
|
List<Address> |
ConsistentHash.locate(Object key,
int replCount)
Locates a key, given a replication count (number of copies). |
Map<Object,List<Address>> |
AbstractConsistentHash.locateAll(Collection<Object> keys,
int replCount)
|
Map<Object,List<Address>> |
ConsistentHash.locateAll(Collection<Object> keys,
int replCount)
The logical equivalent of calling ConsistentHash.locate(Object, int) multiple times for each key in the collection of
keys. |
Methods in org.infinispan.distribution.ch with parameters of type Address | |
---|---|
void |
TopologyInfo.addNodeTopologyInfo(Address addr,
NodeTopologyInfo ti)
|
boolean |
TopologyInfo.containsInfoForNode(Address address)
|
static ConsistentHash |
ConsistentHashHelper.createConsistentHash(Configuration c,
Collection<Address> addresses,
TopologyInfo topologyInfo,
Address... moreAddresses)
Creates a new consistent hash instance based on the user's configuration, and populates the consistent hash with the collection of addresses passed in. |
static ConsistentHash |
ConsistentHashHelper.createConsistentHash(ConsistentHash template,
Collection<Address> addresses,
TopologyInfo topologyInfo,
Address... moreAddresses)
Creates a new consistent hash instance based on the type specified, and populates the consistent hash with the collection of addresses passed in. |
List<Address> |
UnionConsistentHash.getBackupsForNode(Address node,
int replCount)
|
List<Address> |
ExperimentalDefaultConsistentHash.getBackupsForNode(Address node,
int replCount)
|
List<Address> |
AbstractWheelConsistentHash.getBackupsForNode(Address node,
int replCount)
|
List<Address> |
ConsistentHash.getBackupsForNode(Address node,
int replCount)
Returns the nodes that backup data for the supplied node including the node itself. |
int |
DefaultConsistentHash.getDistance(Address a1,
Address a2)
|
int |
ExperimentalDefaultConsistentHash.getDistance(Address a1,
Address a2)
The distance between the first entries in the address array for two caches, a1 and a2. |
int |
UnionConsistentHash.getHashId(Address a)
|
int |
ExperimentalDefaultConsistentHash.getHashId(Address a)
|
int |
AbstractWheelConsistentHash.getHashId(Address a)
|
int |
ConsistentHash.getHashId(Address a)
Returns the value between 0 and the hash space limit, or hash id, for a particular address. |
NodeTopologyInfo |
TopologyInfo.getNodeTopologyInfo(Address address)
|
List<Address> |
DefaultConsistentHash.getStateProvidersOnJoin(Address self,
int replCount)
|
List<Address> |
UnionConsistentHash.getStateProvidersOnJoin(Address joiner,
int replCount)
|
List<Address> |
TopologyAwareConsistentHash.getStateProvidersOnJoin(Address joiner,
int replCount)
In this situation are the same nodes providing state on join as the nodes that provide state on leave. |
List<Address> |
ExperimentalDefaultConsistentHash.getStateProvidersOnJoin(Address joiner,
int replCount)
|
List<Address> |
ConsistentHash.getStateProvidersOnJoin(Address joiner,
int replCount)
Returns the nodes that would act as state providers when a new node joins: - the nodes for which the joiner is a backup - the nodes that held joiner's state |
List<Address> |
DefaultConsistentHash.getStateProvidersOnLeave(Address leaver,
int replCount)
|
List<Address> |
UnionConsistentHash.getStateProvidersOnLeave(Address leaver,
int replCount)
|
List<Address> |
TopologyAwareConsistentHash.getStateProvidersOnLeave(Address leaver,
int replCount)
|
List<Address> |
ExperimentalDefaultConsistentHash.getStateProvidersOnLeave(Address leaver,
int replCount)
|
List<Address> |
ConsistentHash.getStateProvidersOnLeave(Address leaver,
int replCount)
Returns the nodes that need will replicate their state if the specified node crashes. |
boolean |
DefaultConsistentHash.isAdjacent(Address a1,
Address a2)
|
boolean |
ExperimentalDefaultConsistentHash.isAdjacent(Address a1,
Address a2)
Two hashes are adjacent if they are next to each other in the consistent hash. |
boolean |
DefaultConsistentHash.isKeyLocalToAddress(Address target,
Object key,
int replCount)
|
boolean |
AbstractConsistentHash.isKeyLocalToAddress(Address a,
Object key,
int replCount)
|
boolean |
ConsistentHash.isKeyLocalToAddress(Address a,
Object key,
int replCount)
Test to see whether a key is mapped to a given address. |
boolean |
TopologyInfo.isSameMachine(Address a1,
Address a2)
|
boolean |
TopologyInfo.isSameRack(Address a1,
Address a2)
|
boolean |
TopologyInfo.isSameSite(Address a1,
Address a2)
|
static ConsistentHash |
ConsistentHashHelper.removeAddress(ConsistentHash ch,
Address toRemove,
Configuration c,
TopologyInfo topologyInfo)
Returns a new consistent hash of the same type with the given address removed. |
static UnionConsistentHash |
ConsistentHashHelper.removeAddressFromUnionConsistentHash(UnionConsistentHash uch,
Address toRemove,
Configuration c,
TopologyInfo topologyInfo)
Creates a new UnionConsistentHash instance based on the old instance, removing the provided address from both target consistent hash instances in the union. |
void |
TopologyInfo.removeNodeInfo(Address leaver)
|
Method parameters in org.infinispan.distribution.ch with type arguments of type Address | |
---|---|
static ConsistentHash |
ConsistentHashHelper.createConsistentHash(Configuration c,
Collection<Address> addresses,
Collection<Address> moreAddresses,
TopologyInfo topologyInfo)
Creates a new consistent hash instance based on the user's configuration, and populates the consistent hash with the collection of addresses passed in. |
static ConsistentHash |
ConsistentHashHelper.createConsistentHash(Configuration c,
Collection<Address> addresses,
Collection<Address> moreAddresses,
TopologyInfo topologyInfo)
Creates a new consistent hash instance based on the user's configuration, and populates the consistent hash with the collection of addresses passed in. |
static ConsistentHash |
ConsistentHashHelper.createConsistentHash(Configuration c,
Collection<Address> addresses,
TopologyInfo topologyInfo)
Creates a new consistent hash instance based on the user's configuration, and populates the consistent hash with the collection of addresses passed in. |
static ConsistentHash |
ConsistentHashHelper.createConsistentHash(Configuration c,
Collection<Address> addresses,
TopologyInfo topologyInfo,
Address... moreAddresses)
Creates a new consistent hash instance based on the user's configuration, and populates the consistent hash with the collection of addresses passed in. |
static ConsistentHash |
ConsistentHashHelper.createConsistentHash(ConsistentHash template,
Collection<Address> addresses,
TopologyInfo topologyInfo)
Creates a new consistent hash instance based on the type specified, and populates the consistent hash with the collection of addresses passed in. |
static ConsistentHash |
ConsistentHashHelper.createConsistentHash(ConsistentHash template,
Collection<Address> addresses,
TopologyInfo topologyInfo,
Address... moreAddresses)
Creates a new consistent hash instance based on the type specified, and populates the consistent hash with the collection of addresses passed in. |
void |
UnionConsistentHash.setCaches(Set<Address> caches)
|
void |
ExperimentalDefaultConsistentHash.setCaches(Set<Address> caches)
|
void |
AbstractWheelConsistentHash.setCaches(Set<Address> newCaches)
|
void |
AbstractConsistentHash.setCaches(Set<Address> caches)
|
void |
ConsistentHash.setCaches(Set<Address> caches)
Sets the collection of cache addresses in the cluster. |
Constructors in org.infinispan.distribution.ch with parameters of type Address | |
---|---|
ExperimentalDefaultConsistentHash.Entry(Address address,
String string,
int differentiator,
int hash)
|
|
NodeTopologyInfo(String machineId,
String rackId,
String siteId,
Address address)
|
Uses of Address in org.infinispan.lucenedemo |
---|
Methods in org.infinispan.lucenedemo that return types with arguments of type Address | |
---|---|
List<Address> |
DemoActions.listAllMembers()
Returns a list of Addresses of all members in the cluster |
Uses of Address in org.infinispan.manager |
---|
Methods in org.infinispan.manager that return Address | |
---|---|
Address |
DefaultCacheManager.getAddress()
|
Address |
EmbeddedCacheManager.getAddress()
|
Address |
DefaultCacheManager.getCoordinator()
|
Address |
EmbeddedCacheManager.getCoordinator()
|
Methods in org.infinispan.manager that return types with arguments of type Address | |
---|---|
List<Address> |
DefaultCacheManager.getMembers()
|
List<Address> |
EmbeddedCacheManager.getMembers()
|
Uses of Address in org.infinispan.notifications.cachemanagerlistener |
---|
Methods in org.infinispan.notifications.cachemanagerlistener with parameters of type Address | |
---|---|
void |
CacheManagerNotifierImpl.notifyMerge(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId,
boolean needsToRejoin,
List<List<Address>> subgroupsMerged)
|
void |
CacheManagerNotifier.notifyMerge(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId,
boolean requiresRejoin,
List<List<Address>> subgroupsMerged)
|
void |
CacheManagerNotifierImpl.notifyViewChange(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId,
boolean needsToRejoin,
boolean isMerge)
|
void |
CacheManagerNotifier.notifyViewChange(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId,
boolean requiresJoin,
boolean isMerge)
Notifies all registered listeners of a viewChange event. |
Method parameters in org.infinispan.notifications.cachemanagerlistener with type arguments of type Address | |
---|---|
void |
CacheManagerNotifierImpl.notifyMerge(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId,
boolean needsToRejoin,
List<List<Address>> subgroupsMerged)
|
void |
CacheManagerNotifierImpl.notifyMerge(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId,
boolean needsToRejoin,
List<List<Address>> subgroupsMerged)
|
void |
CacheManagerNotifierImpl.notifyMerge(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId,
boolean needsToRejoin,
List<List<Address>> subgroupsMerged)
|
void |
CacheManagerNotifier.notifyMerge(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId,
boolean requiresRejoin,
List<List<Address>> subgroupsMerged)
|
void |
CacheManagerNotifier.notifyMerge(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId,
boolean requiresRejoin,
List<List<Address>> subgroupsMerged)
|
void |
CacheManagerNotifier.notifyMerge(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId,
boolean requiresRejoin,
List<List<Address>> subgroupsMerged)
|
void |
CacheManagerNotifierImpl.notifyViewChange(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId,
boolean needsToRejoin,
boolean isMerge)
|
void |
CacheManagerNotifierImpl.notifyViewChange(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId,
boolean needsToRejoin,
boolean isMerge)
|
void |
CacheManagerNotifier.notifyViewChange(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId,
boolean requiresJoin,
boolean isMerge)
Notifies all registered listeners of a viewChange event. |
void |
CacheManagerNotifier.notifyViewChange(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId,
boolean requiresJoin,
boolean isMerge)
Notifies all registered listeners of a viewChange event. |
Uses of Address in org.infinispan.notifications.cachemanagerlistener.event |
---|
Methods in org.infinispan.notifications.cachemanagerlistener.event that return Address | |
---|---|
Address |
EventImpl.getLocalAddress()
|
Address |
ViewChangedEvent.getLocalAddress()
|
Methods in org.infinispan.notifications.cachemanagerlistener.event that return types with arguments of type Address | |
---|---|
List<Address> |
EventImpl.getNewMembers()
|
List<Address> |
ViewChangedEvent.getNewMembers()
|
List<Address> |
EventImpl.getOldMembers()
|
List<Address> |
ViewChangedEvent.getOldMembers()
|
List<List<Address>> |
EventImpl.getSubgroupsMerged()
|
List<List<Address>> |
MergeEvent.getSubgroupsMerged()
|
Methods in org.infinispan.notifications.cachemanagerlistener.event with parameters of type Address | |
---|---|
void |
EventImpl.setLocalAddress(Address localAddress)
|
Method parameters in org.infinispan.notifications.cachemanagerlistener.event with type arguments of type Address | |
---|---|
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 with parameters of type Address | |
---|---|
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 with type arguments of type Address | |
---|---|
EventImpl(String cacheName,
EmbeddedCacheManager cacheManager,
Event.Type type,
List<Address> newMemberList,
List<Address> oldMemberList,
Address localAddress,
int viewId)
|
|
EventImpl(String cacheName,
EmbeddedCacheManager cacheManager,
Event.Type type,
List<Address> newMemberList,
List<Address> oldMemberList,
Address localAddress,
int viewId)
|
Uses of Address in org.infinispan.remoting |
---|
Methods in org.infinispan.remoting that return Address | |
---|---|
static Address |
MembershipArithmetic.getMemberJoined(List<Address> oldList,
List<Address> newList)
|
static Address |
MembershipArithmetic.getMemberLeft(List<Address> oldList,
List<Address> newList)
|
Methods in org.infinispan.remoting that return types with arguments of type Address | |
---|---|
static List<Address> |
MembershipArithmetic.getMembersJoined(List<Address> oldList,
List<Address> newList)
|
static List<Address> |
MembershipArithmetic.getMembersLeft(List<Address> oldList,
List<Address> newList)
|
Method parameters in org.infinispan.remoting with type arguments of type Address | |
---|---|
static Address |
MembershipArithmetic.getMemberJoined(List<Address> oldList,
List<Address> newList)
|
static Address |
MembershipArithmetic.getMemberJoined(List<Address> oldList,
List<Address> newList)
|
static Address |
MembershipArithmetic.getMemberLeft(List<Address> oldList,
List<Address> newList)
|
static Address |
MembershipArithmetic.getMemberLeft(List<Address> oldList,
List<Address> newList)
|
static List<Address> |
MembershipArithmetic.getMembersJoined(List<Address> oldList,
List<Address> newList)
|
static List<Address> |
MembershipArithmetic.getMembersJoined(List<Address> oldList,
List<Address> newList)
|
static List<Address> |
MembershipArithmetic.getMembersLeft(List<Address> oldList,
List<Address> newList)
|
static List<Address> |
MembershipArithmetic.getMembersLeft(List<Address> oldList,
List<Address> newList)
|
Uses of Address in org.infinispan.remoting.responses |
---|
Methods in org.infinispan.remoting.responses with parameters of type Address | |
---|---|
boolean |
ClusteredGetResponseValidityFilter.isAcceptable(Response response,
Address address)
|
Constructor parameters in org.infinispan.remoting.responses with type arguments of type Address | |
---|---|
ClusteredGetResponseValidityFilter(Collection<Address> pendingResponders)
|
Uses of Address in org.infinispan.remoting.rpc |
---|
Methods in org.infinispan.remoting.rpc that return Address | |
---|---|
Address |
RpcManagerImpl.getAddress()
|
Address |
RpcManager.getAddress()
Returns the address associated with this RpcManager or null if not part of the cluster. |
Address |
RpcManagerImpl.getCurrentStateTransferSource()
|
Address |
RpcManager.getCurrentStateTransferSource()
If RpcManager.retrieveState(String, long) has been invoked and hasn't yet returned (i.e., a state transfer is in
progress), this method will return the current Address from which a state transfer is being attempted. |
Methods in org.infinispan.remoting.rpc that return types with arguments of type Address | |
---|---|
Map<Address,Response> |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
boolean sync,
boolean usePriorityQueue)
|
Map<Address,Response> |
RpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
boolean sync,
boolean usePriorityQueue)
Broadcasts an RPC command to a specified set of recipients |
Map<Address,Response> |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
boolean sync,
boolean usePriorityQueue,
long timeout)
|
Map<Address,Response> |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout)
|
Map<Address,Response> |
RpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout)
Invokes an RPC call on other caches in the cluster. |
Map<Address,Response> |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue)
|
Map<Address,Response> |
RpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue)
Invokes an RPC call on other caches in the cluster. |
Map<Address,Response> |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter)
|
Map<Address,Response> |
RpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter)
Invokes an RPC call on other caches in the cluster. |
Methods in org.infinispan.remoting.rpc with parameters of type Address | |
---|---|
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 |
Method parameters in org.infinispan.remoting.rpc with type arguments of type Address | |
---|---|
void |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
boolean sync)
|
void |
RpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
boolean sync)
Broadcasts an RPC command to a specified set of recipients |
Map<Address,Response> |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
boolean sync,
boolean usePriorityQueue)
|
Map<Address,Response> |
RpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
boolean sync,
boolean usePriorityQueue)
Broadcasts an RPC command to a specified set of recipients |
Map<Address,Response> |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
boolean sync,
boolean usePriorityQueue,
long timeout)
|
Map<Address,Response> |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout)
|
Map<Address,Response> |
RpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout)
Invokes an RPC call on other caches in the cluster. |
Map<Address,Response> |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue)
|
Map<Address,Response> |
RpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue)
Invokes an RPC call on other caches in the cluster. |
Map<Address,Response> |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter)
|
Map<Address,Response> |
RpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter)
Invokes an RPC call on other caches in the cluster. |
void |
RpcManagerImpl.invokeRemotelyInFuture(Collection<Address> recipients,
ReplicableCommand rpc,
boolean usePriorityQueue,
NotifyingNotifiableFuture<Object> l)
|
void |
RpcManager.invokeRemotelyInFuture(Collection<Address> recipients,
ReplicableCommand rpc,
boolean usePriorityQueue,
NotifyingNotifiableFuture<Object> future)
The same as RpcManager.invokeRemotely(java.util.Collection, org.infinispan.commands.ReplicableCommand, boolean)
except that the task is passed to the transport executor and a Future is returned. |
void |
RpcManagerImpl.invokeRemotelyInFuture(Collection<Address> recipients,
ReplicableCommand rpc,
boolean usePriorityQueue,
NotifyingNotifiableFuture<Object> l,
long timeout)
|
void |
RpcManager.invokeRemotelyInFuture(Collection<Address> recipients,
ReplicableCommand rpc,
boolean usePriorityQueue,
NotifyingNotifiableFuture<Object> future,
long timeout)
The same as RpcManager.invokeRemotelyInFuture(java.util.Collection, org.infinispan.commands.ReplicableCommand,
boolean, org.infinispan.util.concurrent.NotifyingNotifiableFuture) except that you can specify a timeout. |
void |
RpcManagerImpl.invokeRemotelyInFuture(Collection<Address> recipients,
ReplicableCommand rpc,
NotifyingNotifiableFuture<Object> l)
|
void |
RpcManager.invokeRemotelyInFuture(Collection<Address> recipients,
ReplicableCommand rpc,
NotifyingNotifiableFuture<Object> future)
The same as RpcManager.invokeRemotely(java.util.Collection, org.infinispan.commands.ReplicableCommand, boolean)
except that the task is passed to the transport executor and a Future is returned. |
Uses of Address in org.infinispan.remoting.transport |
---|
Methods in org.infinispan.remoting.transport that return Address | |
---|---|
Address |
Transport.getAddress()
Retrieves the current cache instance's network address |
Address |
Transport.getCoordinator()
|
Methods in org.infinispan.remoting.transport that return types with arguments of type Address | |
---|---|
List<Address> |
Transport.getMembers()
Returns a list of members in the current cluster view. |
List<Address> |
Transport.getPhysicalAddresses()
Retrieves the current cache instance's physical network addresses. |
Map<Address,Response> |
Transport.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter,
boolean supportReplay)
Invokes an RPC call on other caches in the cluster. |
Methods in org.infinispan.remoting.transport with parameters of type Address | |
---|---|
protected boolean |
AbstractTransport.parseResponseAndAddToResponseList(Object responseObject,
Map<Address,Response> responseListToAddTo,
boolean wasSuspected,
boolean wasReceived,
Address sender,
boolean usedResponseFilter)
|
boolean |
Transport.retrieveState(String cacheName,
Address address,
long timeout)
Initiates a state retrieval from a specific cache (by typically invoking InboundInvocationHandler.generateState(String, java.io.OutputStream) ), and applies this
state to the current cache via the InboundInvocationHandler.applyState(String, java.io.InputStream)
callback. |
Method parameters in org.infinispan.remoting.transport with type arguments of type Address | |
---|---|
Map<Address,Response> |
Transport.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter,
boolean supportReplay)
Invokes an RPC call on other caches in the cluster. |
protected boolean |
AbstractTransport.parseResponseAndAddToResponseList(Object responseObject,
Map<Address,Response> responseListToAddTo,
boolean wasSuspected,
boolean wasReceived,
Address sender,
boolean usedResponseFilter)
|
Uses of Address in org.infinispan.remoting.transport.jgroups |
---|
Classes in org.infinispan.remoting.transport.jgroups that implement Address | |
---|---|
class |
JGroupsAddress
An encapsulation of a JGroups Address |
Fields in org.infinispan.remoting.transport.jgroups declared as Address | |
---|---|
protected Address |
JGroupsTransport.address
|
protected Address |
JGroupsTransport.physicalAddress
|
Fields in org.infinispan.remoting.transport.jgroups with type parameters of type Address | |
---|---|
protected List<Address> |
JGroupsTransport.members
|
Methods in org.infinispan.remoting.transport.jgroups that return Address | |
---|---|
Address |
JGroupsTransport.getAddress()
|
Address |
JGroupsTransport.getCoordinator()
|
Methods in org.infinispan.remoting.transport.jgroups that return types with arguments of type Address | |
---|---|
List<Address> |
JGroupsTransport.getMembers()
|
List<Address> |
JGroupsTransport.getPhysicalAddresses()
|
Map<Address,Response> |
JGroupsTransport.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter,
boolean supportReplay)
|
Methods in org.infinispan.remoting.transport.jgroups with parameters of type Address | |
---|---|
boolean |
JGroupsTransport.retrieveState(String cacheName,
Address address,
long timeout)
|
Method parameters in org.infinispan.remoting.transport.jgroups with type arguments of type Address | |
---|---|
Map<Address,Response> |
JGroupsTransport.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter,
boolean supportReplay)
|
Uses of Address in org.infinispan.transaction.xa |
---|
Fields in org.infinispan.transaction.xa declared as Address | |
---|---|
protected Address |
GlobalTransaction.addr
|
Methods in org.infinispan.transaction.xa that return Address | |
---|---|
Address |
GlobalTransaction.getAddress()
|
Methods in org.infinispan.transaction.xa that return types with arguments of type Address | |
---|---|
Collection<Address> |
LocalTransaction.getRemoteLocksAcquired()
|
Methods in org.infinispan.transaction.xa with parameters of type Address | |
---|---|
boolean |
DldGlobalTransaction.isAcquiringRemoteLock(Object key,
Address address)
|
GlobalTransaction |
GlobalTransactionFactory.newGlobalTransaction(Address addr,
boolean remote)
|
void |
GlobalTransaction.setAddress(Address address)
|
Method parameters in org.infinispan.transaction.xa with type arguments of type Address | |
---|---|
boolean |
LocalTransaction.hasRemoteLocksAcquired(List<Address> leavers)
|
void |
LocalTransaction.locksAcquired(Collection<Address> nodes)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |