|
Brooklyn | |||||||
FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectbrooklyn.entity.basic.AbstractEntity
brooklyn.entity.basic.SoftwareProcessImpl
brooklyn.entity.proxy.AbstractControllerImpl
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 | |
---|---|
EFFECTOR_ADDED, EFFECTOR_CHANGED, EFFECTOR_REMOVED, LOG, 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. |
AbstractEntity
|
configure(java.util.Map flags)
|
protected void
|
connectSensors()
|
protected java.lang.String
|
getAddressOfEntity(Entity member)
|
java.lang.String
|
getDomain()
|
protected 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.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()
|
boolean
|
isActive()
|
void
|
onManagementNoLongerMaster()
|
protected void
|
onServerPoolMemberChanged(Entity member)
|
protected void
|
postRebind()
|
protected void
|
postStart()
|
protected void
|
preStart()
|
protected void
|
preStop()
|
protected void
|
reconfigureService()
|
void
|
reload()
|
protected void
|
removeServerPoolMember(Entity member)
|
protected void
|
resetServerPoolMemberTrackerPolicy()
|
void
|
update()
|
Task
|
updateAsync()
|
void
|
updateNeeded()
|
Field Detail |
---|
protected boolean isActive
protected java.util.Set serverPoolAddresses
protected AbstractMembershipTrackingPolicy serverPoolMemberTrackerPolicy
protected java.util.Map serverPoolTargets
protected boolean updateNeeded
Constructor Detail |
---|
public AbstractControllerImpl()
public AbstractControllerImpl(java.util.Map properties)
public AbstractControllerImpl(Entity parent)
public AbstractControllerImpl(java.util.Map properties, Entity parent)
public AbstractControllerImpl(Entity parent, Cluster cluster)
public AbstractControllerImpl(java.util.Map properties, Entity parent, Cluster cluster)
Method Detail |
---|
protected void addServerPoolMember(Entity member)
protected boolean belongsInServerPool(Entity member)
LOG.warn("Deprecated use of AbstractController.cluster: entity {}; value {}", this, flags.get("cluster")); public void bind(java.util.Map flags)
if (flags.containsKey("cluster")) { public AbstractEntity configure(java.util.Map flags)
resetServerPoolMemberTrackerPolicy(); protected void connectSensors()
protected java.lang.String getAddressOfEntity(Entity member)
return getAttribute(PROXY_HTTP_PORT); public java.lang.String getDomain()
protected AttributeSensor getHostnameSensor()
public String getUrl() { public java.lang.Integer getPort()
} public AttributeSensor getPortNumberSensor()
public String getDomain() { public java.lang.String getProtocol()
// TODO If pool-target entity couldn't be resolved, then serverPoolAddresses and serverPoolTargets public RebindSupport getRebindSupport()
@Override protected java.util.Collection getRequiredOpenPorts()
return getAttribute(PORT_NUMBER_SENSOR); public java.lang.String getUrl()
protected java.lang.String inferProtocol()
protected java.lang.String inferUrl(boolean requireManagementAccessible)
protected java.lang.String inferUrl()
public void init()
return getAttribute(PROTOCOL); public boolean isActive()
private Group getServerPool() { public void onManagementNoLongerMaster()
protected void onServerPoolMemberChanged(Entity member)
@Override protected void postRebind()
@Override protected void postStart()
protected void preStart()
* Implementations should update the configuration so that 'serverPoolAddresses' are targeted. protected void preStop()
protected void reconfigureService()
/** returns URL, if it can be inferred; null otherwise */ public void reload()
protected void removeServerPoolMember(Entity member)
protected void resetServerPoolMemberTrackerPolicy()
Task> result = null; public void update()
public Task updateAsync()
public void updateNeeded()
Brooklyn Multi-Cloud Application Management Platform
brooklyncentral.github.com. Apache License. © 2012.