org.apache.brooklyn.entity.stock

Class AsyncApplicationImpl.ServiceStateComputer

java.lang.Object

org.apache.brooklyn.core.objs.AbstractBrooklynObject

org.apache.brooklyn.core.objs.AbstractEntityAdjunct

org.apache.brooklyn.core.enricher.AbstractEnricher

org.apache.brooklyn.enricher.stock.AbstractAggregator<java.lang.Object,U>

org.apache.brooklyn.enricher.stock.AbstractMultipleSensorAggregator<java.lang.Void>

org.apache.brooklyn.entity.stock.AsyncApplicationImpl.ServiceStateComputer

All Implemented Interfaces:

Rebindable, BrooklynObject, Configurable, EntityAdjunct, Identifiable, Enricher, SensorEventListener<java.lang.Object>, BrooklynObjectInternal

Enclosing class:

AsyncApplicationImpl

public static class AsyncApplicationImpl.ServiceStateComputer
extends AbstractMultipleSensorAggregator<java.lang.Void>
implements SensorEventListener<java.lang.Object>

Calculates the "service.state" and "service.isUp", based on the state of the children. It also transitions from expected=starting to expected=running once all of the children have finished their starting. This does not just rely on the "service.problems" and "service.notUp.indicators" because those make different assumptions about the expected state. Instead it seems much easier to implement the specific logic for async startup here. The important part of the implementation is onUpdated(), and its helper methods for computeServiceUp(Lifecycle), computeServiceState(Lifecycle) and computeExpectedState(Lifecycle, Lifecycle). This class is not to be instantiated directly. Instead, if cusotmization is desired then override AsyncApplicationImpl.initEnrichers() to create and add this enricher (with the same unique tag, to replace the default).

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.brooklyn.core.objs.AbstractEntityAdjunct

AbstractEntityAdjunct.AdjunctTagSupport, AbstractEntityAdjunct.BasicSubscriptionSupport

Nested classes/interfaces inherited from interface org.apache.brooklyn.api.objs.BrooklynObject

BrooklynObject.RelationSupport<T extends BrooklynObject>, BrooklynObject.SubscriptionSupport, BrooklynObject.TagSupport

Nested classes/interfaces inherited from interface org.apache.brooklyn.api.objs.Configurable

Configurable.ConfigurationSupport

Nested classes/interfaces inherited from interface org.apache.brooklyn.core.objs.BrooklynObjectInternal

BrooklynObjectInternal.ConfigurationSupportInternal, BrooklynObjectInternal.RelationSupportInternal<T extends BrooklynObject>, BrooklynObjectInternal.SubscriptionSupportInternal

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DEFAULT_UNIQUE_TAG standard unique tag identifying instances of this enricher at runtime
static ConfigKey<java.util.Set<Lifecycle>>	ENTITY_FAILED_STATES
static ConfigKey<java.util.Set<Lifecycle>>	ENTITY_IGNORED_STATES_ON_OTHERS
static ConfigKey<java.util.Set<Lifecycle>>	ENTITY_IGNORED_STATES_ON_STARTING
static ConfigKey<java.util.Set<Lifecycle>>	ENTITY_TRANSITION_STATES_ON_STARTING
static ConfigKey<java.lang.Boolean>	IGNORE_ENTITIES_WITH_SERVICE_UP_NULL
static ConfigKey<QuorumCheck>	RUNNING_QUORUM_CHECK
static ConfigKey<QuorumCheck>	UP_QUORUM_CHECK

Fields inherited from class org.apache.brooklyn.enricher.stock.AbstractAggregator

DEFAULT_MEMBER_VALUE, ENTITY_FILTER, EXCLUDE_BLANK, FROM_CHILDREN, FROM_HARDCODED_PRODUCERS, FROM_MEMBERS, PRODUCER, TARGET_SENSOR, VALUE_FILTER

Fields inherited from class org.apache.brooklyn.core.enricher.AbstractEnricher

SUPPRESS_DUPLICATES

Fields inherited from class org.apache.brooklyn.core.objs.AbstractEntityAdjunct

HIGHLIGHT_NAME_LAST_ACTION, HIGHLIGHT_NAME_LAST_CONFIRMATION, HIGHLIGHT_NAME_LAST_VIOLATION, HIGHLIGHT_NAME_TRIGGERS

Fields inherited from interface org.apache.brooklyn.api.sensor.SensorEventListener

NOOP

Constructor Summary

Constructors

Constructor and Description
ServiceStateComputer()

Method Summary

Modifier and Type	Method and Description
AsyncApplicationImpl	getEntity()
void	setEntity(EntityLocal entity)

Methods inherited from class org.apache.brooklyn.enricher.stock.AbstractMultipleSensorAggregator

getValues, onEvent

Methods inherited from class org.apache.brooklyn.core.enricher.AbstractEnricher

getEnricherType, getRebindSupport, relations

Methods inherited from class org.apache.brooklyn.core.objs.AbstractEntityAdjunct

config, configure, destroy, getAdjunctType, getConfig, getDisplayName, getExecutionContext, getHighlights, getManagementContext, getUniqueTag, isDestroyed, isRunning, setDisplayName, setHighlights, subscriptions, tags, toString

Methods inherited from class org.apache.brooklyn.core.objs.AbstractBrooklynObject

addSearchPath, getCatalogItemId, getCatalogItemIdSearchPath, getId, init, rebind, setCatalogItemId, setCatalogItemIdAndSearchPath, setManagementContext, stackCatalogItemId

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.brooklyn.api.sensor.SensorEventListener

onEvent

Methods inherited from interface org.apache.brooklyn.api.sensor.Enricher

getId

Methods inherited from interface org.apache.brooklyn.api.objs.EntityAdjunct

getHighlights, getUniqueTag, isDestroyed, isRunning

Methods inherited from interface org.apache.brooklyn.api.objs.BrooklynObject

getCatalogItemId, getCatalogItemIdSearchPath, getDisplayName, subscriptions, tags

Methods inherited from interface org.apache.brooklyn.api.objs.Configurable

config, getConfig

Methods inherited from interface org.apache.brooklyn.core.objs.BrooklynObjectInternal

addSearchPath, setCatalogItemId, setCatalogItemIdAndSearchPath, stackCatalogItemId

Field Detail

DEFAULT_UNIQUE_TAG

public static final java.lang.String DEFAULT_UNIQUE_TAG

standard unique tag identifying instances of this enricher at runtime

See Also:

Constant Field Values

RUNNING_QUORUM_CHECK

public static final ConfigKey<QuorumCheck> RUNNING_QUORUM_CHECK

UP_QUORUM_CHECK

public static final ConfigKey<QuorumCheck> UP_QUORUM_CHECK

ENTITY_FAILED_STATES

public static final ConfigKey<java.util.Set<Lifecycle>> ENTITY_FAILED_STATES

ENTITY_TRANSITION_STATES_ON_STARTING

public static final ConfigKey<java.util.Set<Lifecycle>> ENTITY_TRANSITION_STATES_ON_STARTING

ENTITY_IGNORED_STATES_ON_STARTING

public static final ConfigKey<java.util.Set<Lifecycle>> ENTITY_IGNORED_STATES_ON_STARTING

ENTITY_IGNORED_STATES_ON_OTHERS

public static final ConfigKey<java.util.Set<Lifecycle>> ENTITY_IGNORED_STATES_ON_OTHERS

IGNORE_ENTITIES_WITH_SERVICE_UP_NULL

public static final ConfigKey<java.lang.Boolean> IGNORE_ENTITIES_WITH_SERVICE_UP_NULL

Constructor Detail

ServiceStateComputer

public ServiceStateComputer()

Method Detail

getEntity

public AsyncApplicationImpl getEntity()

Overrides:

getEntity in class AbstractEntityAdjunct

setEntity

public void setEntity(EntityLocal entity)

Overrides:

setEntity in class AbstractAggregator<java.lang.Object,java.lang.Void>