Package | Description |
---|---|
org.wildfly.clustering.dispatcher |
Public clustering API which facilitates remote command execution
on the cluster.
|
org.wildfly.clustering.group |
Public clustering API which represent cluster group and its members.
|
org.wildfly.clustering.provider |
Public clustering API for registering services on a group of nodes.
|
org.wildfly.clustering.registry |
Public clustering API for clustered registry that stores a unique key/value pair per node.
|
org.wildfly.clustering.server.dispatcher | |
org.wildfly.clustering.server.group | |
org.wildfly.clustering.server.logging | |
org.wildfly.clustering.server.provider | |
org.wildfly.clustering.server.registry | |
org.wildfly.clustering.server.singleton | |
org.wildfly.clustering.singleton | |
org.wildfly.clustering.singleton.election | |
org.wildfly.extension.clustering.singleton.election |
Modifier and Type | Method and Description |
---|---|
<R> Map<Node,CommandResponse<R>> |
CommandDispatcher.executeOnCluster(Command<R,C> command,
Node... excludedNodes)
Execute the specified command on all nodes in the group, excluding the specified nodes
|
<R> Map<Node,Future<R>> |
CommandDispatcher.submitOnCluster(Command<R,C> command,
Node... excludedNodes)
Submits the specified command on all nodes in the group, excluding the specified nodes.
|
Modifier and Type | Method and Description |
---|---|
<R> Map<Node,CommandResponse<R>> |
CommandDispatcher.executeOnCluster(Command<R,C> command,
Node... excludedNodes)
Execute the specified command on all nodes in the group, excluding the specified nodes
|
<R> CommandResponse<R> |
CommandDispatcher.executeOnNode(Command<R,C> command,
Node node)
Execute the specified command on the specified node.
|
<R> Map<Node,Future<R>> |
CommandDispatcher.submitOnCluster(Command<R,C> command,
Node... excludedNodes)
Submits the specified command on all nodes in the group, excluding the specified nodes.
|
<R> Future<R> |
CommandDispatcher.submitOnNode(Command<R,C> command,
Node node)
Submits the specified command on the specified node for execution.
|
Modifier and Type | Method and Description |
---|---|
Node |
NodeFactory.createNode(A address)
Creates a node instance from the address.
|
Node |
Group.getCoordinatorNode()
Returns the group coordinator node.
|
Node |
Group.getLocalNode()
Returns the local node.
|
Modifier and Type | Method and Description |
---|---|
List<Node> |
Group.getNodes()
Returns the list of nodes that are members of this group.
|
Modifier and Type | Method and Description |
---|---|
void |
Group.Listener.membershipChanged(List<Node> previousMembers,
List<Node> members,
boolean merged)
Indicates that the membership of the group has changed.
|
void |
Group.Listener.membershipChanged(List<Node> previousMembers,
List<Node> members,
boolean merged)
Indicates that the membership of the group has changed.
|
Modifier and Type | Method and Description |
---|---|
Set<Node> |
ServiceProviderRegistration.getProviders()
Returns the set of nodes that can provide this service.
|
Set<Node> |
ServiceProviderRegistry.getProviders(T service)
Returns the set of nodes that can provide the specified service.
|
Modifier and Type | Method and Description |
---|---|
void |
ServiceProviderRegistration.Listener.providersChanged(Set<Node> nodes)
Indicates that the set of nodes providing a given service has changed.
|
Modifier and Type | Method and Description |
---|---|
Map.Entry<K,V> |
Registry.getEntry(Node node)
Returns the registry entry for the specified node.
|
Modifier and Type | Method and Description |
---|---|
Node |
ChannelCommandDispatcherFactory.getCoordinatorNode() |
Node |
ChannelCommandDispatcherFactory.getLocalNode() |
Modifier and Type | Method and Description |
---|---|
<R> Map<Node,CommandResponse<R>> |
LocalCommandDispatcher.executeOnCluster(Command<R,C> command,
Node... excludedNodes) |
<R> Map<Node,CommandResponse<R>> |
ChannelCommandDispatcher.executeOnCluster(Command<R,C> command,
Node... excludedNodes) |
List<Node> |
ChannelCommandDispatcherFactory.getNodes() |
<R> Map<Node,Future<R>> |
LocalCommandDispatcher.submitOnCluster(Command<R,C> command,
Node... excludedNodes) |
<R> Map<Node,Future<R>> |
ChannelCommandDispatcher.submitOnCluster(Command<R,C> command,
Node... excludedNodes) |
Modifier and Type | Method and Description |
---|---|
<R> Map<Node,CommandResponse<R>> |
LocalCommandDispatcher.executeOnCluster(Command<R,C> command,
Node... excludedNodes) |
<R> Map<Node,CommandResponse<R>> |
ChannelCommandDispatcher.executeOnCluster(Command<R,C> command,
Node... excludedNodes) |
<R> CommandResponse<R> |
LocalCommandDispatcher.executeOnNode(Command<R,C> command,
Node node) |
<R> CommandResponse<R> |
ChannelCommandDispatcher.executeOnNode(Command<R,C> command,
Node node) |
<R> Map<Node,Future<R>> |
LocalCommandDispatcher.submitOnCluster(Command<R,C> command,
Node... excludedNodes) |
<R> Map<Node,Future<R>> |
ChannelCommandDispatcher.submitOnCluster(Command<R,C> command,
Node... excludedNodes) |
<R> Future<R> |
LocalCommandDispatcher.submitOnNode(Command<R,C> command,
Node node) |
<R> Future<R> |
ChannelCommandDispatcher.submitOnNode(Command<R,C> command,
Node node) |
Constructor and Description |
---|
LocalCommandDispatcher(Node node,
C context) |
LocalCommandDispatcher(Node node,
C context,
ExecutorService executor) |
Modifier and Type | Class and Description |
---|---|
class |
AddressableNode
Node implementation that associates a JGroups
Address with its logical name
and transport socket binding. |
class |
LocalNode
Non-clustered
Node implementation. |
Modifier and Type | Method and Description |
---|---|
Node |
CacheNodeFactory.createNode(org.infinispan.remoting.transport.Address address) |
Node |
LocalNodeFactory.createNode(org.jgroups.Address address) |
Node |
ChannelNodeFactory.createNode(org.jgroups.Address key) |
Node |
CacheGroup.getCoordinatorNode() |
Node |
LocalGroup.getCoordinatorNode() |
Node |
CacheGroup.getLocalNode() |
Node |
LocalGroup.getLocalNode() |
Modifier and Type | Method and Description |
---|---|
List<Node> |
CacheGroup.getNodes() |
List<Node> |
LocalGroup.getNodes() |
Constructor and Description |
---|
LocalGroup(String name,
Node node) |
Modifier and Type | Method and Description |
---|---|
void |
ClusteringServerLogger_$logger.registryPurgeFailed(org.infinispan.commons.CacheException e,
String containerName,
String cacheName,
Collection<Node> nodes) |
void |
ClusteringServerLogger.registryPurgeFailed(org.infinispan.commons.CacheException e,
String containerName,
String cacheName,
Collection<Node> nodes) |
void |
ClusteringServerLogger_$logger.serviceProviderRegistrationListenerFailed(Throwable e,
String containerName,
String cacheName,
Set<Node> providers) |
void |
ClusteringServerLogger.serviceProviderRegistrationListenerFailed(Throwable e,
String containerName,
String cacheName,
Set<Node> providers) |
Modifier and Type | Method and Description |
---|---|
org.infinispan.Cache<T,Set<Node>> |
CacheServiceProviderRegistryConfiguration.getCache() |
org.infinispan.Cache<T,Set<Node>> |
CacheServiceProviderRegistryBuilder.getCache() |
Set<Node> |
AbstractServiceProviderRegistration.getProviders() |
Set<Node> |
ServiceProviderRegistrationFactoryAdapter.getProviders(T service)
Returns the set of nodes that can provide the specified service.
|
Set<Node> |
LocalServiceProviderRegistry.getProviders(T service) |
Set<Node> |
CacheServiceProviderRegistry.getProviders(T service) |
Modifier and Type | Method and Description |
---|---|
void |
CacheServiceProviderRegistry.membershipChanged(List<Node> previousMembers,
List<Node> members,
boolean merged) |
void |
CacheServiceProviderRegistry.membershipChanged(List<Node> previousMembers,
List<Node> members,
boolean merged) |
void |
CacheServiceProviderRegistry.modified(org.infinispan.notifications.cachelistener.event.CacheEntryEvent<org.jboss.msc.service.ServiceName,Set<Node>> event) |
Modifier and Type | Method and Description |
---|---|
org.infinispan.Cache<Node,Map.Entry<K,V>> |
CacheRegistryFactoryConfiguration.getCache() |
org.infinispan.Cache<Node,Map.Entry<K,V>> |
CacheRegistryFactoryBuilder.getCache() |
Modifier and Type | Method and Description |
---|---|
Map.Entry<K,V> |
CacheRegistry.getEntry(Node node) |
Map.Entry<K,V> |
LocalRegistry.getEntry(Node node) |
Modifier and Type | Method and Description |
---|---|
void |
CacheRegistry.event(org.infinispan.notifications.cachelistener.event.CacheEntryEvent<Node,Map.Entry<K,V>> event) |
void |
CacheRegistry.removed(org.infinispan.notifications.cachelistener.event.CacheEntryRemovedEvent<Node,Map.Entry<K,V>> event) |
void |
CacheRegistry.topologyChanged(org.infinispan.notifications.cachelistener.event.TopologyChangedEvent<Node,Map.Entry<K,V>> event) |
Modifier and Type | Method and Description |
---|---|
void |
CacheSingletonServiceBuilder.providersChanged(Set<Node> nodes) |
Modifier and Type | Method and Description |
---|---|
Node |
SingletonElectionPolicy.elect(List<Node> nodes)
Elect a single node from the specified list of candidate nodes.
|
Modifier and Type | Method and Description |
---|---|
Node |
SingletonElectionPolicy.elect(List<Node> nodes)
Elect a single node from the specified list of candidate nodes.
|
Modifier and Type | Method and Description |
---|---|
Node |
PreferredSingletonElectionPolicy.elect(List<Node> candidates) |
Node |
SimpleSingletonElectionPolicy.elect(List<Node> candidates) |
Node |
RandomSingletonElectionPolicy.elect(List<Node> nodes)
Elect a single node from the specified list of candidate nodes.
|
Modifier and Type | Method and Description |
---|---|
boolean |
Preference.preferred(Node node) |
boolean |
SocketAddressPreference.preferred(Node node) |
boolean |
NamePreference.preferred(Node node) |
Modifier and Type | Method and Description |
---|---|
Node |
PreferredSingletonElectionPolicy.elect(List<Node> candidates) |
Node |
SimpleSingletonElectionPolicy.elect(List<Node> candidates) |
Node |
RandomSingletonElectionPolicy.elect(List<Node> nodes)
Elect a single node from the specified list of candidate nodes.
|
Modifier and Type | Method and Description |
---|---|
boolean |
OutboundSocketBindingPreference.preferred(Node node) |
Copyright © 2017 JBoss by Red Hat. All rights reserved.