public interface RedundancyManager
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
SYSTEM_ID |
Modifier and Type | Method and Description |
---|---|
void |
addMessageReceiver(java.lang.String protocol,
MessageReceiver recv)
Adds a message receiver for the clustered task system.
|
void |
addRedundancyStateListener(RedundancyStateListener l)
The redundancy state listener will be notified each time there is a change to any part of the redundancy state.
|
void |
applySettings(RedundancySettings settings) |
java.io.Serializable |
executeTask(RedundantTask task)
Takes a RedundantTask and executes it locally before replicating it to the clustered backup node.
|
java.io.Serializable |
executeTask(RedundantTask task,
boolean async) |
java.io.Serializable |
executeTask(java.lang.String protocol,
java.io.Serializable message)
This executes a task locally, and then replicates the task to the backup node IF the execution didn't produce an
exception.
|
java.io.Serializable |
executeTask(java.lang.String protocol,
java.io.Serializable message,
boolean async) |
void |
forceConfigurationSync()
Requests that the system execute a full config sync.
|
GatewayAddressGroup |
getAllHttpAddresses()
Lists the HTTP urls for the gateways in the redundant cluster.
|
java.lang.Object |
getConfigLock()
The following were part of the cluster manager, and may or may not be appropriate for this interface.
|
RedundancyState |
getCurrentState() |
java.lang.String |
getLocalAddress()
Returns the network address of the local machine.
|
java.lang.Long |
getMasterStartTime()
Returns the time, coordinated for this node, that the master last started.
|
java.util.List<MetricValue> |
getMetrics() |
PeerStatus |
getPeerConnectionStatus() |
SystemMap |
getPeerSystemMap() |
RuntimeStateManager |
getRuntimeStateManager()
Provides the RuntimeStateManager.
|
RedundancySettings |
getSettings() |
boolean |
isActive()
Returns whether the system is currently "active", i.e., the node should be running fully.
|
boolean |
isAutoDetectHttp() |
boolean |
isMaster()
Returns whether this node's responsibility is MASTER.
|
boolean |
isRedundancyEnabled() |
void |
postTask(java.lang.String protocol,
java.io.Serializable message)
Similar to executeTask, but does not deliver the task locally before sending it on.
|
void |
removeMessageReceiver(java.lang.String protocol,
MessageReceiver recv) |
void |
removeRedundancyStateListener(RedundancyStateListener l) |
void |
requestPeerActivityLevel(ActivityLevel level)
Request that the peer assume either Active or Inactive activity.
|
void |
shutdown() |
static final java.lang.String SYSTEM_ID
RedundancyState getCurrentState()
PeerStatus getPeerConnectionStatus()
boolean isRedundancyEnabled()
boolean isActive()
boolean isMaster()
void requestPeerActivityLevel(ActivityLevel level)
void forceConfigurationSync()
java.lang.Long getMasterStartTime()
void addRedundancyStateListener(RedundancyStateListener l)
l
- void removeRedundancyStateListener(RedundancyStateListener l)
void addMessageReceiver(java.lang.String protocol, MessageReceiver recv)
protocol
- a unique string identifier for messages that will be delivered to the given receiver.recv
- a listener who will receive clustered tasks sent on the specified protocol.void removeMessageReceiver(java.lang.String protocol, MessageReceiver recv)
java.io.Serializable executeTask(java.lang.String protocol, java.io.Serializable message) throws java.lang.Exception
protocol
- message
- java.lang.Exception
java.io.Serializable executeTask(java.lang.String protocol, java.io.Serializable message, boolean async) throws java.lang.Exception
java.lang.Exception
void postTask(java.lang.String protocol, java.io.Serializable message) throws java.lang.Exception
protocol
- message
- java.lang.Exception
java.io.Serializable executeTask(RedundantTask task) throws java.lang.Exception
task
- java.lang.Exception
executeTask(String, Serializable)
java.io.Serializable executeTask(RedundantTask task, boolean async) throws java.lang.Exception
java.lang.Exception
RuntimeStateManager getRuntimeStateManager()
void shutdown()
RedundancySettings getSettings()
void applySettings(RedundancySettings settings)
java.lang.Object getConfigLock()
boolean isAutoDetectHttp()
GatewayAddressGroup getAllHttpAddresses()
SystemMap getPeerSystemMap()
java.util.List<MetricValue> getMetrics()
java.lang.String getLocalAddress()