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
  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 boolean isActive

protected java.util.Set serverPoolAddresses

protected AbstractMembershipTrackingPolicy serverPoolMemberTrackerPolicy

protected java.util.Map serverPoolTargets

protected boolean updateNeeded

 
Fields inherited from class SoftwareProcessImpl
connectedSensors
 
Fields inherited from class AbstractEntity
CHILD_ADDED, CHILD_REMOVED, EFFECTOR_ADDED, EFFECTOR_CHANGED, EFFECTOR_REMOVED, POLICY_ADDED, POLICY_REMOVED, SENSOR_ADDED, SENSOR_REMOVED, _subscriptionTracker, 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.

protected void connectSensors()

protected java.lang.String getAddressOfEntity(Entity member)

java.lang.String getDomain()

AttributeSensor getHostAndPortSensor()

AttributeSensor getHostnameSensor()

java.lang.Integer getPort()

primary URL this controller serves, if one can / has been inferred
AttributeSensor getPortNumberSensor()

java.lang.String getProtocol()

returns primary domain this controller responds to, or null if it responds to all domains
RebindSupport getRebindSupport()

protected java.util.Collection getRequiredOpenPorts()

java.util.Set getServerPoolAddresses()

ProxySslConfig getSslConfig()

java.lang.String getUrl()

protected java.lang.String inferProtocol()

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

protected java.lang.String inferUrl()

void init()

protected void initServerPoolMemberTrackingPolicy()

boolean isActive()

boolean isSsl()

void onManagementNoLongerMaster()

protected void onServerPoolMemberChanged(Entity member)

protected void postRebind()

protected void postStart()

protected void preStart()

protected void preStop()

protected void rebind()

protected void reconfigureService()

void reload()

protected void removeServerPoolMember(Entity member)

protected void resetServerPoolMemberTrackerPolicy()

void update()

Task updateAsync()

void updateNeeded()

 
Methods inherited from class SoftwareProcessImpl
callRebindHooks, callStartHooks, checkModifiable, connectSensors, connectServiceUpIsRunning, disconnectSensors, disconnectServiceUpIsRunning, doInitDriver, doRestart, doStart, doStop, getDriver, getLocalHostname, getMachineOrNull, getProvisioningLocation, getRequiredOpenPorts, newDriver, obtainProvisioningFlags, onManagementStarted, onManagementStarting, postDriverStart, postRebind, postStart, preStart, preStop, rebind, restart, setProvisioningLocation, start, startInLocation, startInLocation, startInLocation, startInLocation, stop, waitForEntityStart, waitForServiceUp, waitForServiceUp, waitForServiceUp, waitForServiceUp
 
Methods inherited from class AbstractEntity
addChild, addChild, addEnricher, addEnricher, addGroup, addLocations, addPolicy, addPolicy, clearLocations, clearParent, configure, configure, configure, configure, configure, configure, destroy, emit, emitInternal, equals, finalize, firstLocation, getAllAttributes, getAllConfig, getAllConfigBag, getApplication, getApplicationId, getAttribute, getAttributeByNameParts, getChildren, getConfig, getConfig, getConfig, getConfig, getConfigMap, getConfigRaw, getConfigRaw, getCreationTime, getDisplayName, getEffector, getEnrichers, getEntityManager, getEntityType, getEntityTypeName, getExecutionContext, getGroups, getIconUrl, getId, getLocalConfigBag, getLocations, getManagementContext, getManagementSupport, getMutableEntityType, getParent, getPolicies, getProxy, getProxyIfAvailable, getRebindSupport, getSubscriptionContext, getSubscriptionTracker, hashCode, init, invalidateReferences, invoke, invoke, invoke, isLegacyConstruction, onManagementBecomingMaster, onManagementNoLongerMaster, onManagementStarted, onManagementStarting, onManagementStopped, refreshInheritedConfig, removeAllEnrichers, removeAllPolicies, removeAttribute, removeChild, removeEnricher, removeLocations, removePolicy, setApplication, setAttribute, setAttribute, setAttributeWithoutPublishing, setConfig, setConfig, setConfig, setConfig, setConfig, setConfig, setConfigEvenIfOwned, setConfigEvenIfOwned, setConfigIfValNonNull, setConfigIfValNonNull, setDefaultDisplayName, setDisplayName, setManagementContext, setParent, setProxy, subscribe, subscribeToChildren, subscribeToMembers, toMetadataRecord, toString, toStringHelper, unsubscribe, unsubscribe
 

Field Detail

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

@java.lang.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 'serverPool'.

connectSensors

@java.lang.Override}
protected void connectSensors()

getAddressOfEntity

protected java.lang.String getAddressOfEntity(Entity member)

getDomain

@java.lang.Overridereturn getAttribute(PROXY_HTTP_PORT);
public java.lang.String getDomain()

getHostAndPortSensor

@java.lang.Overridereturn serverPoolAddresses;
public AttributeSensor getHostAndPortSensor()

getHostnameSensor

@java.lang.Overridereturn getAttribute(HOST_AND_PORT_SENSOR);
public AttributeSensor getHostnameSensor()

getPort

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

getPortNumberSensor

@java.lang.Overridereturn getAttribute(HOSTNAME_SENSOR);
public AttributeSensor getPortNumberSensor()

getProtocol

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

getRebindSupport

@java.lang.Override// will be out-of-sync (for ever more?)
public RebindSupport getRebindSupport()

getRequiredOpenPorts

@java.lang.Overrideprotected void preStart() {
protected java.util.Collection getRequiredOpenPorts()

getServerPoolAddresses

@java.lang.Override
public java.util.Set getServerPoolAddresses()

getSslConfig

@java.lang.Overridereturn getAttribute(PROTOCOL);
public ProxySslConfig getSslConfig()

getUrl

@java.lang.Overridereturn getAttribute(PORT_NUMBER_SENSOR);
public java.lang.String getUrl()

inferProtocol

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

inferUrl

protected java.lang.String inferUrl(boolean requireManagementAccessible)

inferUrl

protected java.lang.String inferUrl()

init

@java.lang.Override
public void init()

initServerPoolMemberTrackingPolicy

protected void initServerPoolMemberTrackingPolicy()

isActive

@java.lang.Overridereturn getSslConfig() != null;
public boolean isActive()

isSsl

@java.lang.Overridereturn getConfig(SSL_CONFIG);
public boolean isSsl()

onManagementNoLongerMaster

@java.lang.Override}
public void onManagementNoLongerMaster()

onServerPoolMemberChanged

protected void onServerPoolMemberChanged(Entity member)

postRebind

@java.lang.Overrideprotected void preStop() {
protected void postRebind()

postStart

@java.lang.Overrideprotected void postRebind() {
protected void postStart()

preStart

@java.lang.OverridecheckState(!hostnameSensor.isPresent() && !portSensor.isPresent(),
protected void preStart()

preStop

@java.lang.Override* Implementations should update the configuration so that 'serverPoolAddresses' are targeted.
protected void preStop()

rebind

@java.lang.Overridesuper.rebind();
    }
protected void rebind()

reconfigureService

protected void reconfigureService()

reload

@java.lang.Override/** returns URL, if it can be inferred; null otherwise */
public void reload()

removeServerPoolMember

protected void removeServerPoolMember(Entity member)

resetServerPoolMemberTrackerPolicy

protected void resetServerPoolMemberTrackerPolicy()

update

@java.lang.Overrideif (!isActive()) updateNeeded = true;
public void update()

updateAsync

public Task updateAsync()

updateNeeded

public void updateNeeded()

 

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