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.provider | |
org.wildfly.clustering.server.registry | |
org.wildfly.clustering.server.singleton | |
org.wildfly.clustering.singleton | |
org.wildfly.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> |
ServiceProviderRegistrationFactory.getProviders(Object service)
Returns the set of nodes that 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 |
---|---|
<R> Map<Node,CommandResponse<R>> |
ServiceCommandDispatcher.executeOnCluster(Command<R,C> command,
Node... excludedNodes) |
<R> Map<Node,Future<R>> |
ServiceCommandDispatcher.submitOnCluster(Command<R,C> command,
Node... excludedNodes) |
Modifier and Type | Method and Description |
---|---|
<R> Map<Node,CommandResponse<R>> |
ServiceCommandDispatcher.executeOnCluster(Command<R,C> command,
Node... excludedNodes) |
<R> CommandResponse<R> |
ServiceCommandDispatcher.executeOnNode(Command<R,C> command,
Node node) |
<R> Map<Node,Future<R>> |
ServiceCommandDispatcher.submitOnCluster(Command<R,C> command,
Node... excludedNodes) |
<R> Future<R> |
ServiceCommandDispatcher.submitOnNode(Command<R,C> command,
Node node) |
Modifier and Type | Class and Description |
---|---|
class |
AddressableNode
Node implementation that associates a JGroups
Address with its logical name
and transport socket binding. |
Modifier and Type | Method and Description |
---|---|
Node |
ChannelNodeFactoryService.createNode(org.jgroups.Address address) |
Node |
CacheNodeFactoryService.createNode(org.infinispan.remoting.transport.Address address) |
Node |
ChannelGroupService.getCoordinatorNode() |
Node |
CacheGroupService.getCoordinatorNode() |
Node |
ChannelGroupService.getLocalNode() |
Node |
CacheGroupService.getLocalNode() |
Modifier and Type | Method and Description |
---|---|
List<Node> |
ChannelGroupService.getNodes() |
List<Node> |
CacheGroupService.getNodes() |
Modifier and Type | Method and Description |
---|---|
org.infinispan.Cache<Object,Set<Node>> |
ServiceProviderRegistrationFactoryConfiguration.getCache() |
Set<Node> |
ServiceProviderRegistrationFactoryService.getProviders(Object service) |
Modifier and Type | Method and Description |
---|---|
void |
ServiceProviderRegistrationFactoryService.membershipChanged(List<Node> previousMembers,
List<Node> members,
boolean merged) |
void |
ServiceProviderRegistrationFactoryService.membershipChanged(List<Node> previousMembers,
List<Node> members,
boolean merged) |
void |
ServiceProviderRegistrationFactoryService.modified(org.infinispan.notifications.cachelistener.event.CacheEntryModifiedEvent<org.jboss.msc.service.ServiceName,Set<Node>> event) |
Modifier and Type | Method and Description |
---|---|
org.infinispan.Cache<Node,Map.Entry<K,V>> |
RegistryFactoryConfiguration.getCache() |
Modifier and Type | Method and Description |
---|---|
Map.Entry<K,V> |
RegistryFactoryService.getEntry(Node node) |
Modifier and Type | Method and Description |
---|---|
void |
RegistryFactoryService.modified(org.infinispan.notifications.cachelistener.event.CacheEntryModifiedEvent<Node,Map.Entry<K,V>> event) |
void |
RegistryFactoryService.removed(org.infinispan.notifications.cachelistener.event.CacheEntryRemovedEvent<Node,Map.Entry<K,V>> event) |
void |
RegistryFactoryService.topologyChanged(org.infinispan.notifications.cachelistener.event.TopologyChangedEvent<org.infinispan.remoting.transport.Address,Node> event) |
Modifier and Type | Method and Description |
---|---|
void |
SingletonService.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) |
Modifier and Type | Method and Description |
---|---|
boolean |
SocketAddressPreference.preferred(Node node) |
boolean |
Preference.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) |
Copyright © 2014 JBoss by Red Hat. All rights reserved.