|
||||||||||
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 |
---|
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.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. |
List<Address> |
DistributionManagerImpl.requestPermissionToJoin(Address a)
|
List<Address> |
DistributionManager.requestPermissionToJoin(Address joiner)
"Asks" a coordinator if a joiner may join. |
Methods in org.infinispan.distribution with parameters of type Address | |
---|---|
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)
|
List<Address> |
DistributionManagerImpl.requestPermissionToJoin(Address a)
|
List<Address> |
DistributionManager.requestPermissionToJoin(Address joiner)
"Asks" a coordinator if a joiner may join. |
void |
DistributionManagerImpl.setSelf(Address self)
|
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)
|
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> leavers,
List<Address> stateProviders,
List<Address> stateReceivers,
boolean isReceiver)
|
|
InvertedLeaveTask(DistributionManagerImpl dmi,
RpcManager rpcManager,
Configuration conf,
CommandsFactory commandsFactory,
DataContainer dataContainer,
List<Address> leavers,
List<Address> stateProviders,
List<Address> stateReceivers,
boolean isReceiver)
|
|
InvertedLeaveTask(DistributionManagerImpl dmi,
RpcManager rpcManager,
Configuration conf,
CommandsFactory commandsFactory,
DataContainer dataContainer,
List<Address> leavers,
List<Address> stateProviders,
List<Address> stateReceivers,
boolean isReceiver)
|
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 ArrayList<Address> |
AbstractWheelConsistentHash.addresses
|
protected Map<Address,Integer> |
AbstractWheelConsistentHash.addressToHashIds
|
protected List<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> |
DefaultConsistentHash.getAddressOnTheWheel()
|
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. |
List<Address> |
UnionConsistentHash.getCaches()
|
List<Address> |
ExperimentalDefaultConsistentHash.getCaches()
|
List<Address> |
AbstractWheelConsistentHash.getCaches()
|
List<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,
List<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,
List<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,
List<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,
List<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,
List<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,
List<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,
List<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,
List<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(List<Address> caches)
|
void |
ExperimentalDefaultConsistentHash.setCaches(List<Address> caches)
|
void |
AbstractWheelConsistentHash.setCaches(List<Address> caches)
|
void |
AbstractConsistentHash.setCaches(List<Address> caches)
|
void |
ConsistentHash.setCaches(List<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)
|
void |
CacheManagerNotifier.notifyViewChange(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId,
boolean requiresJoin)
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)
|
void |
CacheManagerNotifierImpl.notifyViewChange(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId,
boolean needsToRejoin)
|
void |
CacheManagerNotifier.notifyViewChange(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId,
boolean requiresJoin)
Notifies all registered listeners of a viewChange event. |
void |
CacheManagerNotifier.notifyViewChange(List<Address> members,
List<Address> oldMembers,
Address myAddress,
int viewId,
boolean requiresJoin)
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 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 |
List<Response> |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
boolean sync,
boolean usePriorityQueue)
|
List<Response> |
RpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
boolean sync,
boolean usePriorityQueue)
Broadcasts an RPC command to a specified set of recipients |
List<Response> |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
boolean sync,
boolean usePriorityQueue,
long timeout)
|
List<Response> |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout)
|
List<Response> |
RpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout)
Invokes an RPC call on other caches in the cluster. |
List<Response> |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue)
|
List<Response> |
RpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue)
Invokes an RPC call on other caches in the cluster. |
List<Response> |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter)
|
List<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. |
Methods in org.infinispan.remoting.transport with parameters of type Address | |
---|---|
protected boolean |
AbstractTransport.parseResponseAndAddToResponseList(Object responseObject,
List<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 | |
---|---|
List<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. |
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()
|
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 | |
---|---|
List<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)
|
|
Google Analytics | |||||||||
PREV NEXT | FRAMES NO FRAMES |