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

brooklyn.entity.proxy
[Java] Class AbstractControllerImpl

java.lang.Object
  groovy.lang.GroovyObjectSupport
      brooklyn.entity.basic.AbstractEntity
          brooklyn.entity.basic.SoftwareProcessImpl
              brooklyn.entity.proxy.AbstractControllerImpl
All Implemented Interfaces:
AbstractController
public abstract class AbstractControllerImpl
extends SoftwareProcessImpl

Represents a controller mechanism for a Cluster.

Field Summary
protected static Logger LOG

protected boolean isActive

protected java.util.Set serverPoolAddresses

protected AbstractMembershipTrackingPolicy serverPoolMemberTrackerPolicy

protected java.util.Map serverPoolTargets

protected boolean updateNeeded

 
Fields inherited from class SoftwareProcessImpl
sensorRegistry
 
Fields inherited from class AbstractEntity
LOG, POLICY_ADDED, POLICY_REMOVED, SENSOR_ADDED, SENSOR_REMOVED, _subscriptionTracker, attributesInternal, configsInternal, managementSupport, tempWorkings
 
Constructor Summary
AbstractControllerImpl()

AbstractControllerImpl(java.util.Map properties)

AbstractControllerImpl(Entity parent)

AbstractControllerImpl(java.util.Map properties, Entity parent)

AbstractControllerImpl(Entity parent, Cluster cluster)

AbstractControllerImpl(java.util.Map properties, Entity parent, Cluster cluster)

 
Method Summary
protected void addServerPoolMember(Entity member)

protected boolean belongsInServerPool(Entity member)

void bind(java.util.Map flags)

Opportunity to do late-binding of the cluster that is being controlled.

AbstractEntity configure(java.util.Map flags)

protected void connectSensors()

protected java.lang.String getAddressOfEntity(Entity member)

java.lang.String getDomain()

returns primary domain this controller responds to, or null if it responds to all domains
java.lang.Integer getPort()

AttributeSensor getPortNumberSensor()

java.lang.String getProtocol()

RebindSupport getRebindSupport()

protected java.util.Collection getRequiredOpenPorts()

java.lang.String getUrl()

primary URL this controller serves, if one can / has been inferred
protected java.lang.String inferProtocol()

protected java.lang.String inferUrl(boolean requireManagementAccessible)

returns URL, if it can be inferred; null otherwise
protected java.lang.String inferUrl()

boolean isActive()

void onManagementNoLongerMaster()

protected void onServerPoolMemberChanged(Entity member)

protected void postRebind()

protected void postStart()

protected void preStart()

protected void preStop()

protected void reconfigureService()

Implementations should update the configuration so that 'serverPoolAddresses' are targeted.

void reload()

protected void removeServerPoolMember(Entity member)

protected void resetServerPoolMemberTrackerPolicy()

void update()

 
Methods inherited from class SoftwareProcessImpl
callRebindHooks, callStartHooks, checkModifiable, connectSensors, connectServiceUpIsRunning, disconnectSensors, disconnectServiceUpIsRunning, doInitDriver, getDriver, getLocalHostname, getMachineOrNull, getProvisioningFlags, getProvisioningLocation, getRequiredOpenPorts, newDriver, obtainProvisioningFlags, onManagementStarted, onManagementStarting, postDriverRestart, postDriverStart, postRebind, postRestart, postStart, preStart, preStop, rebind, restart, setProvisioningLocation, start, startInLocation, startInLocation, startInLocation, startInLocation, stop, stopInLocation, waitForEntityStart, waitForServiceUp, waitForServiceUp, waitForServiceUp
 
Methods inherited from class AbstractEntity
addChild, addChild, addEnricher, addGroup, addLocations, addOwnedChild, addPolicy, assertNotYetOwned, clearOwner, clearParent, configure, configure, configure, configure, configure, createManagementSupport, destroy, emit, emitInternal, equals, finalize, firstLocation, getAllAttributes, getAllConfig, getApplication, getApplicationId, getAttribute, getAttributeByNameParts, getChildren, getChildrenReference, getConfig, getConfig, getConfig, getConfig, getConfigMap, getDisplayName, getEffector, getEnrichers, getEntityManager, getEntityType, getEntityTypeName, getExecutionContext, getGroups, getId, getLocations, getManagementContext, getManagementSupport, getMutableEntityType, getOwnedChildren, getOwnedChildrenReference, getOwner, getParent, getPolicies, getProxy, getProxyIfAvailable, getRebindSupport, getSubscriptionContext, getSubscriptionTracker, hasEverBeenManaged, hashCode, init, invalidateReferences, invoke, invoke, invokeFromJava, invokeMethod, isLegacyConstruction, onManagementBecomingMaster, onManagementNoLongerMaster, onManagementStarted, onManagementStarting, refreshInheritedConfig, refreshInheritedConfigOfChildren, removeAllEnrichers, removeAllPolicies, removeAttribute, removeChild, removeEnricher, removeLocations, removeOwnedChild, removePolicy, setApplication, setAttribute, setAttribute, setAttributeWithoutPublishing, setBeingManaged, setConfig, setConfig, setConfig, setConfig, setConfig, setConfig, setConfigEvenIfOwned, setConfigEvenIfOwned, setConfigIfValNonNull, setConfigIfValNonNull, setDisplayName, setManagementContext, setOwner, setParent, setProxy, subscribe, subscribeToChildren, subscribeToMembers, toString, toStringFieldsToInclude, toStringHelper, unsubscribe, unsubscribe
 
Methods inherited from class groovy.lang.GroovyObjectSupport
groovy.lang.GroovyObjectSupport#setProperty(java.lang.String, java.lang.Object), groovy.lang.GroovyObjectSupport#getProperty(java.lang.String), groovy.lang.GroovyObjectSupport#getMetaClass(), groovy.lang.GroovyObjectSupport#setMetaClass(groovy.lang.MetaClass), groovy.lang.GroovyObjectSupport#invokeMethod(java.lang.String, java.lang.Object), groovy.lang.GroovyObjectSupport#wait(), groovy.lang.GroovyObjectSupport#wait(long), groovy.lang.GroovyObjectSupport#wait(long, int), groovy.lang.GroovyObjectSupport#equals(java.lang.Object), groovy.lang.GroovyObjectSupport#toString(), groovy.lang.GroovyObjectSupport#hashCode(), groovy.lang.GroovyObjectSupport#getClass(), groovy.lang.GroovyObjectSupport#notify(), groovy.lang.GroovyObjectSupport#notifyAll()
 

Field Detail

LOG

protected static final Logger LOG

isActive

protected boolean isActive

serverPoolAddresses

protected java.util.Set serverPoolAddresses

serverPoolMemberTrackerPolicy

protected AbstractMembershipTrackingPolicy serverPoolMemberTrackerPolicy

serverPoolTargets

protected java.util.Map serverPoolTargets

updateNeeded

protected boolean updateNeeded

 
Constructor Detail

AbstractControllerImpl

public AbstractControllerImpl()

AbstractControllerImpl

public AbstractControllerImpl(java.util.Map properties)

AbstractControllerImpl

public AbstractControllerImpl(Entity parent)

AbstractControllerImpl

public AbstractControllerImpl(java.util.Map properties, Entity parent)

AbstractControllerImpl

public AbstractControllerImpl(Entity parent, Cluster cluster)

AbstractControllerImpl

public AbstractControllerImpl(java.util.Map properties, Entity parent, Cluster cluster)

 
Method Detail

addServerPoolMember

protected void addServerPoolMember(Entity member)

belongsInServerPool

protected boolean belongsInServerPool(Entity member)

bind

@Override
public void bind(java.util.Map flags)
Opportunity to do late-binding of the cluster that is being controlled. Must be called before start(). Can pass in the 'cluster'.

configure

@Override
public AbstractEntity configure(java.util.Map flags)

connectSensors

@Override
protected void connectSensors()

getAddressOfEntity

protected java.lang.String getAddressOfEntity(Entity member)

getDomain

@Override
public java.lang.String getDomain()
returns primary domain this controller responds to, or null if it responds to all domains

getPort

@Override
public java.lang.Integer getPort()

getPortNumberSensor

@Override
public AttributeSensor getPortNumberSensor()

getProtocol

@Override
public java.lang.String getProtocol()

getRebindSupport

@Override
public RebindSupport getRebindSupport()

getRequiredOpenPorts

@Override
protected java.util.Collection getRequiredOpenPorts()

getUrl

@Override
public java.lang.String getUrl()
primary URL this controller serves, if one can / has been inferred

inferProtocol

protected java.lang.String inferProtocol()

inferUrl

protected java.lang.String inferUrl(boolean requireManagementAccessible)
returns URL, if it can be inferred; null otherwise

inferUrl

protected java.lang.String inferUrl()

isActive

@Override
public boolean isActive()

onManagementNoLongerMaster

@Override
public void onManagementNoLongerMaster()

onServerPoolMemberChanged

protected void onServerPoolMemberChanged(Entity member)

postRebind

@Override
protected void postRebind()

postStart

@Override
protected void postStart()

preStart

@Override
protected void preStart()

preStop

@Override
protected void preStop()

reconfigureService

protected void reconfigureService()
Implementations should update the configuration so that 'serverPoolAddresses' are targeted. The caller will subsequently call reload to apply the new configuration.

reload

@Override
public void reload()

removeServerPoolMember

protected void removeServerPoolMember(Entity member)

resetServerPoolMemberTrackerPolicy

protected void resetServerPoolMemberTrackerPolicy()

update

@Override
public void update()

 

Brooklyn Multi-Cloud Application Management Platform
brooklyncentral.github.com. Apache License. © 2012.