Overview  Package   Class  Deprecated  Index  Help 
Brooklyn
FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

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

Field Summary
static ConfigKey MEMBER_FILTER

static ConfigKey ONLY_REPORT_IF_PREVIOUSLY_UP

static ConfigKey USE_SERVICE_STATE_RUNNING

 
Fields inherited from class AbstractPolicy
policyStatus, suspended
 
Fields inherited from class AbstractEntityAdjunct
_subscriptionTracker, adjunctType, configsInternal, entity, execution, id, leftoverProperties, name
 
Constructor Summary
MemberFailureDetectionPolicy()

MemberFailureDetectionPolicy(java.util.Map flags)

 
Method Summary
protected boolean acceptsMember(Entity member)

void setEntity(EntityLocal entity)

 
Methods inherited from class AbstractPolicy
destroy, getPolicyType, getRebindSupport, isRunning, isSuspended, resume, suspend, toString
 
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
 

Field Detail

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

 
Constructor Detail

MemberFailureDetectionPolicy

public MemberFailureDetectionPolicy()

MemberFailureDetectionPolicy

public MemberFailureDetectionPolicy(java.util.Map flags)

 
Method Detail

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.