|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Address | |
---|---|
org.infinispan.context.impl | |
org.infinispan.demo | |
org.infinispan.distribution | Classes relating to the distributed cache mode. |
org.infinispan.manager | Cache manager package |
org.infinispan.notifications.cachemanagerlistener | |
org.infinispan.notifications.cachemanagerlistener.event | |
org.infinispan.remoting.responses | |
org.infinispan.remoting.rpc | |
org.infinispan.remoting.transport | |
org.infinispan.remoting.transport.jgroups | |
org.infinispan.transaction.xa |
Uses of Address in org.infinispan.context.impl |
---|
Fields in org.infinispan.context.impl with type parameters of type Address | |
---|---|
protected Set<Address> |
AbstractTxInvocationContext.txParticipants
|
Methods in org.infinispan.context.impl that return types with arguments of type Address | |
---|---|
Set<Address> |
TxInvocationContext.getTransactionParticipants()
Returns the set of cluster participants (identified through Address
objects) that participate within the transaction. |
Set<Address> |
AbstractTxInvocationContext.getTransactionParticipants()
|
Method parameters in org.infinispan.context.impl with type arguments of type Address | |
---|---|
void |
TxInvocationContext.addTransactionParticipants(List<Address> addresses)
Registers a new participant with the transaction. |
void |
AbstractTxInvocationContext.addTransactionParticipants(List<Address> addresses)
|
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 types with arguments of type Address | |
---|---|
List<Address> |
DistributionManagerImpl.locate(Object key)
|
List<Address> |
DistributionManager.locate(Object key)
Locates a key in a cluster. |
List<Address> |
DefaultConsistentHash.locate(Object key,
int replicationCount)
|
List<Address> |
ConsistentHash.locate(Object key,
int replCount)
|
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>> |
DefaultConsistentHash.locateAll(Collection<Object> keys,
int replCount)
|
Map<Object,List<Address>> |
ConsistentHash.locateAll(Collection<Object> keys,
int replCount)
|
Method parameters in org.infinispan.distribution with type arguments of type Address | |
---|---|
void |
DistributionManagerImpl.rehash(Collection<Address> newList)
|
void |
DistributionManager.rehash(Collection<Address> newList)
|
void |
DefaultConsistentHash.setCaches(Collection<Address> caches)
|
void |
ConsistentHash.setCaches(Collection<Address> caches)
|
Uses of Address in org.infinispan.manager |
---|
Methods in org.infinispan.manager that return Address | |
---|---|
Address |
DefaultCacheManager.getAddress()
|
Address |
CacheManager.getAddress()
|
Methods in org.infinispan.manager that return types with arguments of type Address | |
---|---|
List<Address> |
DefaultCacheManager.getMembers()
|
List<Address> |
CacheManager.getMembers()
|
Uses of Address in org.infinispan.notifications.cachemanagerlistener |
---|
Methods in org.infinispan.notifications.cachemanagerlistener with parameters of type Address | |
---|---|
void |
CacheManagerNotifierImpl.notifyViewChange(List<Address> members,
Address myAddress)
|
void |
CacheManagerNotifier.notifyViewChange(List<Address> members,
Address myAddress)
Notifies all registered listeners of a viewChange event. |
Method parameters in org.infinispan.notifications.cachemanagerlistener with type arguments of type Address | |
---|---|
void |
CacheManagerNotifierImpl.notifyViewChange(List<Address> members,
Address myAddress)
|
void |
CacheManagerNotifier.notifyViewChange(List<Address> members,
Address myAddress)
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 |
ViewChangedEvent.getLocalAddress()
|
Address |
EventImpl.getLocalAddress()
|
Methods in org.infinispan.notifications.cachemanagerlistener.event that return types with arguments of type Address | |
---|---|
List<Address> |
ViewChangedEvent.getNewMemberList()
|
List<Address> |
EventImpl.getNewMemberList()
|
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.setNewMemberList(List<Address> newMemberList)
|
Constructors in org.infinispan.notifications.cachemanagerlistener.event with parameters of type Address | |
---|---|
EventImpl(String cacheName,
CacheManager cacheManager,
Event.Type type,
List<Address> newMemberList,
Address localAddress)
|
Constructor parameters in org.infinispan.notifications.cachemanagerlistener.event with type arguments of type Address | |
---|---|
EventImpl(String cacheName,
CacheManager cacheManager,
Event.Type type,
List<Address> newMemberList,
Address localAddress)
|
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.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.anycastRpcCommand(List<Address> recipients,
ReplicableCommand rpc,
boolean sync)
|
void |
RpcManager.anycastRpcCommand(List<Address> recipients,
ReplicableCommand rpc,
boolean sync)
Broadcasts an RPC command to a specified set of recipients |
void |
RpcManagerImpl.anycastRpcCommand(List<Address> recipients,
ReplicableCommand rpc,
boolean sync,
boolean usePriorityQueue)
|
void |
RpcManager.anycastRpcCommand(List<Address> recipients,
ReplicableCommand rpc,
boolean sync,
boolean usePriorityQueue)
Broadcasts an RPC command to a specified set of recipients |
Future<Object> |
RpcManagerImpl.anycastRpcCommandInFuture(List<Address> recipients,
ReplicableCommand rpc)
|
Future<Object> |
RpcManager.anycastRpcCommandInFuture(List<Address> recipients,
ReplicableCommand rpc)
The same as RpcManager.anycastRpcCommand(java.util.List, org.infinispan.commands.ReplicableCommand, boolean) except
that the task is passed to the transport executor and a Future is returned. |
Future<Object> |
RpcManagerImpl.anycastRpcCommandInFuture(List<Address> recipients,
ReplicableCommand rpc,
boolean usePriorityQueue)
|
Future<Object> |
RpcManager.anycastRpcCommandInFuture(List<Address> recipients,
ReplicableCommand rpc,
boolean usePriorityQueue)
The same as RpcManager.anycastRpcCommand(java.util.List, org.infinispan.commands.ReplicableCommand, boolean) except
that the task is passed to the transport executor and a Future is returned. |
List<Response> |
RpcManagerImpl.invokeRemotely(List<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout)
|
List<Response> |
RpcManager.invokeRemotely(List<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout)
Invokes an RPC call on other caches in the cluster. |
List<Response> |
RpcManagerImpl.invokeRemotely(List<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue)
|
List<Response> |
RpcManager.invokeRemotely(List<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue)
Invokes an RPC call on other caches in the cluster. |
List<Response> |
RpcManagerImpl.invokeRemotely(List<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter)
|
List<Response> |
RpcManager.invokeRemotely(List<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter)
Invokes an RPC call on other caches in the cluster. |
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. |
Methods in org.infinispan.remoting.transport with parameters of type Address | |
---|---|
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(List<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 |
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()
|
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(List<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter,
boolean supportReplay)
|
Uses of Address in org.infinispan.transaction.xa |
---|
Methods in org.infinispan.transaction.xa with parameters of type Address | |
---|---|
void |
GlobalTransaction.setAddress(Address address)
|
Constructors in org.infinispan.transaction.xa with parameters of type Address | |
---|---|
GlobalTransaction(Address addr,
boolean remote)
|
|
GlobalTransaction(long id,
Address addr)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |