| Modifier and Type | Field and Description |
|---|---|
| private volatile boolean | |
| private long | |
| private final ClusterManager | |
| private final Map | |
| private final DeploymentManager | |
| private volatile boolean | |
| private volatile FailoverCompleteHandler | |
| private final String | |
| private final JsonObject | haInfo
References Deprecated
JsonObject is deprecated or references (maybe indirectly) at least one deprecated element.
|
| private volatile boolean | |
| private static final Logger | |
| private final String | |
| private static final long | |
| private final int | |
| private long | |
| private volatile boolean | |
| private final Queue | |
| private final VerticleManager | |
| private final VertxInternal |
| Access | Constructor and Description |
|---|---|
| public | HAManager(VertxInternal vertx, DeploymentManager deploymentManager, VerticleManager verticleFactoryManager, ClusterManager clusterManager, Map<String, String> clusterMap, int quorumSize, String group)
|
| Modifier and Type | Method and Description |
|---|---|
| public void | addDataToAHAInfo(String key, JsonObject value)
References Deprecated
JsonObject is deprecated or references (maybe indirectly) at least one deprecated element.
|
| private void | |
| private void | |
| private void | addToHADeployList(final String verticleName, final DeploymentOptions deploymentOptions, final Handler<AsyncResult<String>> doneHandler)
|
| private void | checkFailover(String failedNodeID, JsonObject theHAInfo)
References Deprecated
JsonObject is deprecated or references (maybe indirectly) at least one deprecated element.
|
| private void | |
| private void | |
| private synchronized void | |
| private String | |
| private void | |
| public void | deployVerticle(final String verticleName, DeploymentOptions deploymentOptions, final Handler<AsyncResult<String>> doneHandler)
|
| private void | doDeployVerticle(final String verticleName, DeploymentOptions deploymentOptions, final Handler<AsyncResult<String>> doneHandler)
|
| public void | |
| pack-priv void | init()
Initialize the ha manager, i.e register the node listener to propagates the node events and start the quorum timer. |
| public boolean | |
| private synchronized void | |
| private synchronized void | |
| private void | processFailover(JsonObject failedVerticle)
References Deprecated
JsonObject is deprecated or references (maybe indirectly) at least one deprecated element.
|
| public void | |
| private void | |
| public void | |
| public void | |
| public void | |
| private void |
| attainedQuorum | back to summary |
|---|---|
| private volatile boolean attainedQuorum | |
| checkQuorumTimerID | back to summary |
|---|---|
| private long checkQuorumTimerID | |
| clusterManager | back to summary |
|---|---|
| private final ClusterManager clusterManager | |
| clusterMap | back to summary |
|---|---|
| private final Map<String, String> clusterMap | |
| deploymentManager | back to summary |
|---|---|
| private final DeploymentManager deploymentManager | |
| failDuringFailover | back to summary |
|---|---|
| private volatile boolean failDuringFailover | |
| failoverCompleteHandler | back to summary |
|---|---|
| private volatile FailoverCompleteHandler failoverCompleteHandler | |
| group | back to summary |
|---|---|
| private final String group | |
| haInfo | back to summary |
|---|---|
| private final JsonObject haInfo
References Deprecated
See corresponding docs for further information. | |
| killed | back to summary |
|---|---|
| private volatile boolean killed | |
| log | back to summary |
|---|---|
| private static final Logger log | |
| nodeID | back to summary |
|---|---|
| private final String nodeID | |
| QUORUM_CHECK_PERIOD | back to summary |
|---|---|
| private static final long QUORUM_CHECK_PERIOD | |
| quorumSize | back to summary |
|---|---|
| private final int quorumSize | |
| quorumTimerID | back to summary |
|---|---|
| private long quorumTimerID | |
| stopped | back to summary |
|---|---|
| private volatile boolean stopped | |
| toDeployOnQuorum | back to summary |
|---|---|
| private final Queue<Runnable> toDeployOnQuorum | |
| verticleFactoryManager | back to summary |
|---|---|
| private final VerticleManager verticleFactoryManager | |
| vertx | back to summary |
|---|---|
| private final VertxInternal vertx | |
| HAManager | back to summary |
|---|---|
| public HAManager(VertxInternal vertx, DeploymentManager deploymentManager, VerticleManager verticleFactoryManager, ClusterManager clusterManager, Map<String, String> clusterMap, int quorumSize, String group) | |
| addDataToAHAInfo | back to summary |
|---|---|
| public void addDataToAHAInfo(String key, JsonObject value)
References Deprecated
See corresponding docs for further information. | |
| addHaInfoIfLost | back to summary |
|---|---|
| private void addHaInfoIfLost() | |
| addToHA | back to summary |
|---|---|
| private void addToHA(String deploymentID, String verticleName, DeploymentOptions deploymentOptions) | |
| addToHADeployList | back to summary |
|---|---|
| private void addToHADeployList(final String verticleName, final DeploymentOptions deploymentOptions, final Handler<AsyncResult<String>> doneHandler) | |
| checkFailover | back to summary |
|---|---|
| private void checkFailover(String failedNodeID, JsonObject theHAInfo)
References Deprecated
See corresponding docs for further information. | |
| checkHADeployments | back to summary |
|---|---|
| private void checkHADeployments() | |
| checkQuorum | back to summary |
|---|---|
| private void checkQuorum() | |
| checkQuorumWhenAdded | back to summary |
|---|---|
| private synchronized void checkQuorumWhenAdded(final String nodeID, final long start) | |
| chooseHashedNode | back to summary |
|---|---|
| private String chooseHashedNode(String group, int hashCode) | |
| deployHADeployments | back to summary |
|---|---|
| private void deployHADeployments() | |
| deployVerticle | back to summary |
|---|---|
| public void deployVerticle(final String verticleName, DeploymentOptions deploymentOptions, final Handler<AsyncResult<String>> doneHandler) | |
| doDeployVerticle | back to summary |
|---|---|
| private void doDeployVerticle(final String verticleName, DeploymentOptions deploymentOptions, final Handler<AsyncResult<String>> doneHandler) | |
| failDuringFailover | back to summary |
|---|---|
| public void failDuringFailover(boolean fail) | |
| init | back to summary |
|---|---|
| pack-priv void init() Initialize the ha manager, i.e register the node listener to propagates the node events and start the quorum timer. The quorum will be checked as well. | |
| isKilled | back to summary |
|---|---|
| public boolean isKilled() | |
| nodeAdded | back to summary |
|---|---|
| private synchronized void nodeAdded(final String nodeID) | |
| nodeLeft | back to summary |
|---|---|
| private synchronized void nodeLeft(String leftNodeID) | |
| processFailover | back to summary |
|---|---|
| private void processFailover(JsonObject failedVerticle)
References Deprecated
See corresponding docs for further information. | |
| removeFromHA | back to summary |
|---|---|
| public void removeFromHA(String depID) | |
| runOnContextAndWait | back to summary |
|---|---|
| private void runOnContextAndWait(Runnable runnable) | |
| setFailoverCompleteHandler | back to summary |
|---|---|
| public void setFailoverCompleteHandler(FailoverCompleteHandler failoverCompleteHandler) | |
| simulateKill | back to summary |
|---|---|
| public void simulateKill() | |
| stop | back to summary |
|---|---|
| public void stop() | |
| undeployHADeployments | back to summary |
|---|---|
| private void undeployHADeployments() | |