brooklyn.policy.ha
[Java] Class MemberFailureDetectionPolicy
java.lang.Object
brooklyn.policy.basic.AbstractEntityAdjunct
brooklyn.policy.basic.AbstractPolicy
brooklyn.policy.ha.MemberFailureDetectionPolicy
public class MemberFailureDetectionPolicy
extends AbstractPolicy
Detects when members of a group have failed/recovered, and emits ENTITY_FAILED or
ENTITY_RECOVERED accordingly.
This policy should be associated with a group to monitor its members:
group.addPolicy(new MemberFailureDetectionPolicy(...));
Basic "failure" is defined as the service being "running" but isUp having flipped from
true to false.
These criteria can be further configured using "onlyReportIfPreviouslyUp" and
"useServiceStateRunning".
- Authors:
- aled
Methods inherited from class AbstractEntityAdjunct
|
check, configure, configure, destroy, doReconfigureConfig, getAdjunctType, getAllConfig, getAllSubscriptions, getConfig, getConfigMap, getId, getManagementContext, getName, getSubscriptionTracker, init, isDestroyed, isLegacyConstruction, isRunning, setConfig, setEntity, setId, setManagementContext, setName, subscribe, subscribeToChildren, subscribeToMembers, toString, unsubscribe, unsubscribe |
MEMBER_FILTER
public static final ConfigKey MEMBER_FILTER
-
ONLY_REPORT_IF_PREVIOUSLY_UP
public static final ConfigKey> MEMBER_FILTER = (ConfigKey) ConfigKeys.newConfigKey(Predicate.class, "memberFilter", "", Predicates.alwaysTrue());
public static final ConfigKey ONLY_REPORT_IF_PREVIOUSLY_UP
-
USE_SERVICE_STATE_RUNNING
private final Map memberLastUps = Maps.newLinkedHashMap();
public static final ConfigKey USE_SERVICE_STATE_RUNNING
-
MemberFailureDetectionPolicy
public MemberFailureDetectionPolicy()
-
MemberFailureDetectionPolicy
public MemberFailureDetectionPolicy(java.util.Map flags)
-
acceptsMember
protected boolean acceptsMember(Entity member)
-
setEntity
if (!acceptsMember(event.getSource())) return;
public void setEntity(EntityLocal entity)
-
Brooklyn Multi-Cloud Application Management Platform
brooklyncentral.github.com. Apache License. © 2012.