|
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.nosql.cassandra.CassandraNodeImpl
public class CassandraNodeImpl extends SoftwareProcessImpl
Implementation of CassandraNode.
Field Summary |
---|
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 | |
CassandraNodeImpl()
|
Method Summary | |
---|---|
protected void
|
connectEnrichers()
|
protected void
|
connectEnrichers(Duration windowPeriod)
|
protected void
|
connectSensors()
|
void
|
disconnectSensors()
|
java.lang.String
|
getBroadcastAddress()
|
java.lang.String
|
getClusterName()
|
java.lang.String
|
getDatacenterName()
|
CassandraNodeDriver
|
getDriver()
|
java.lang.Class
|
getDriverInterface()
|
java.lang.Integer
|
getGossipPort()
|
java.lang.String
|
getListenAddress()
|
java.lang.String
|
getPrivateIp()
|
java.lang.String
|
getPublicIp()
|
java.lang.String
|
getRackName()
|
java.lang.String
|
getSeeds()
|
java.lang.Integer
|
getSslGossipPort()
|
java.lang.Integer
|
getThriftPort()
|
java.lang.Long
|
getToken()
|
void
|
init()
|
protected boolean
|
requiresAlwaysPublicIp()
Some clouds (e.g. |
void
|
setToken(java.lang.String token)
|
Constructor Detail |
---|
public CassandraNodeImpl()
Method Detail |
---|
protected void connectEnrichers()
protected void connectEnrichers(Duration windowPeriod)
.entity(this) .period(3000, TimeUnit.MILLISECONDS) protected void connectSensors()
public void setToken(String token) { public void disconnectSensors()
@Override public java.lang.String getBroadcastAddress()
@Override public java.lang.String getClusterName()
public java.lang.String getDatacenterName()
public CassandraNodeDriver getDriver()
} public java.lang.Class getDriverInterface()
@Override public java.lang.Integer getGossipPort()
@Override public java.lang.String getListenAddress()
public java.lang.String getPrivateIp()
public java.lang.String getPublicIp()
public java.lang.String getRackName()
lo public java.lang.String getSeeds()
@Override public java.lang.Integer getSslGossipPort()
@Override public java.lang.Integer getThriftPort()
@Override public java.lang.Long getToken()
private JmxHelper jmxHelper; public void init()
protected boolean requiresAlwaysPublicIp()
} public void setToken(java.lang.String token)
Brooklyn Multi-Cloud Application Management Platform
brooklyncentral.github.com. Apache License. © 2012.