public class ConnectionFailureDetector extends AbstractPolicy
HostAndPort, to emit HASensors.CONNECTION_FAILED and HASensors.CONNECTION_RECOVERED
if the connection is lost/restored.| Modifier and Type | Class and Description |
|---|---|
class |
ConnectionFailureDetector.CalculatedStatus |
static class |
ConnectionFailureDetector.LastPublished |
BrooklynObject.TagSupport| Modifier and Type | Field and Description |
|---|---|
static BasicNotificationSensor<HASensors.FailureDescriptor> |
CONNECTION_FAILED |
static ConfigKey<Duration> |
CONNECTION_FAILED_STABILIZATION_DELAY |
static BasicNotificationSensor<HASensors.FailureDescriptor> |
CONNECTION_RECOVERED |
static ConfigKey<Duration> |
CONNECTION_RECOVERED_STABILIZATION_DELAY |
static ConfigKey<com.google.common.net.HostAndPort> |
ENDPOINT |
static ConfigKey<Duration> |
POLL_PERIOD |
| Constructor and Description |
|---|
ConnectionFailureDetector() |
| Modifier and Type | Method and Description |
|---|---|
void |
init()
Called by framework (in new-style instances where spec was used) after configuring etc,
but before a reference to this instance is shared.
|
void |
resume()
Resume the policy
|
void |
setEntity(EntityLocal entity) |
void |
suspend()
Suspend the policy
|
destroy, getPolicyType, getRebindSupport, isRunning, isSuspended, toStringconfigure, getAllConfig, getConfig, getConfigMap, getDisplayName, getName, getUniqueTag, isDestroyed, setConfig, setDisplayName, setName, tagsgetCatalogItemId, getId, getManagementContext, getTagSupport, rebind, setCatalogItemId, setManagementContextequals, getClass, hashCode, notify, notifyAll, wait, wait, waitgetAllConfig, getConfig, getId, getName, setConfiggetUniqueTag, isDestroyedgetCatalogItemId, getDisplayName, getTagSupport, tagssetCatalogItemIdpublic static final ConfigKey<com.google.common.net.HostAndPort> ENDPOINT
public static final BasicNotificationSensor<HASensors.FailureDescriptor> CONNECTION_FAILED
public static final BasicNotificationSensor<HASensors.FailureDescriptor> CONNECTION_RECOVERED
public static final ConfigKey<Duration> CONNECTION_FAILED_STABILIZATION_DELAY
public void init()
AbstractBrooklynObjectTo preserve backwards compatibility for if the instance is constructed directly, one can call the code below, but that means it will be called after references to this policy have been shared with other entities.
if (isLegacyConstruction()) {
init();
}
init in class AbstractBrooklynObjectpublic void setEntity(EntityLocal entity)
setEntity in class AbstractEntityAdjunctpublic void suspend()
Policysuspend in interface Policysuspend in class AbstractPolicypublic void resume()
Policyresume in interface Policyresume in class AbstractPolicy