public class CouchbaseNodeImpl extends SoftwareProcessImpl implements CouchbaseNode
CouchbaseNode.MainUri
SoftwareProcess.ChildStartableMode, SoftwareProcess.RestartSoftwareParameters, SoftwareProcess.StopSoftwareParameters
BrooklynObject.TagSupport
Configurable.ConfigurationSupport
Startable.RestartEffectorBody, Startable.StartEffectorBody, Startable.StopEffectorBody
EntityInternal.FeedSupport
BrooklynObjectInternal.ConfigurationSupportInternal
CHILD_ADDED, CHILD_REMOVED, EFFECTOR_ADDED, EFFECTOR_CHANGED, EFFECTOR_REMOVED, LOCATION_ADDED, LOCATION_REMOVED, POLICY_ADDED, POLICY_REMOVED, SENSOR_ADDED, SENSOR_REMOVED
ADD_REPLICATION_RULE, BUCKET_CREATE, CMD_GET, COUCH_DOCS_ACTUAL_DISK_SIZE, COUCH_DOCS_DATA_SIZE, COUCH_VIEWS_ACTUAL_DISK_SIZE, COUCH_VIEWS_DATA_SIZE, COUCHBASE_ADMIN_PASSWORD, COUCHBASE_ADMIN_USERNAME, COUCHBASE_API_PORT, COUCHBASE_CAPI_HTTPS_FOR_SSL, COUCHBASE_CLIENT_INTERFACE_PROXY, COUCHBASE_CLUSTER_INIT_RAM_SIZE, COUCHBASE_INCOMING_SSL_PROXY, COUCHBASE_INTERNAL_BUCKET_PORT, COUCHBASE_INTERNAL_EXTERNAL_BUCKET_PORT, COUCHBASE_INTERNAL_OUTGOING_SSL_PROXY, COUCHBASE_REST_HTTPS_FOR_SSL, COUCHBASE_WEB_ADMIN_PORT, COUCHBASE_WEB_ADMIN_URL, CURR_ITEMS, CURR_ITEMS_TOT, DOWNLOAD_URL, EP_BG_FETCHED, ERLANG_PORT_MAPPER, GET_HITS, IS_IN_CLUSTER, IS_PRIMARY_NODE, MAIN_URI, MEM_USED, NODE_DATA_EXCHANGE_PORT_RANGE_END, NODE_DATA_EXCHANGE_PORT_RANGE_START, OPS, REBALANCE, REBALANCE_STATUS, SERVER_ADD, SERVER_ADD_AND_REBALANCE, SUGGESTED_VERSION, USE_ENTERPRISE, VB_REPLICA_CURR_ITEMS
ADDRESS, CHILDREN_STARTABLE_MODE, CUSTOMIZE_LATCH, DOWNLOAD_ADDON_URLS, ENTITY_STARTED, EXPANDED_INSTALL_DIR, HOSTNAME, INSTALL_DIR, INSTALL_FILES, INSTALL_LATCH, INSTALL_RESOURCES_LATCH, INSTALL_TEMPLATES, INSTALL_UNIQUE_LABEL, LAUNCH_LATCH, MAXIMUM_REBIND_SENSOR_CONNECT_DELAY, PID_FILE, POST_INSTALL_COMMAND, POST_LAUNCH_COMMAND, PRE_INSTALL_COMMAND, PRE_INSTALL_FILES, PRE_INSTALL_TEMPLATES, PRE_LAUNCH_COMMAND, PROVISIONING_LOCATION, PROVISIONING_PROPERTIES, REQUIRED_OPEN_LOGIN_PORTS, RUN_DIR, RUNTIME_FILES, RUNTIME_RESOURCES_LATCH, RUNTIME_TEMPLATES, SERVICE_PROCESS_IS_RUNNING, SERVICE_STATE_ACTUAL, SERVICE_STATE_EXPECTED, SETUP_LATCH, SHELL_ENVIRONMENT, SKIP_ENTITY_START_IF_RUNNING, SKIP_INSTALLATION, START_LATCH, START_TIMEOUT, SUBNET_ADDRESS, SUBNET_HOSTNAME, SUGGESTED_INSTALL_DIR, SUGGESTED_RUN_DIR
RESTART, SERVICE_UP, START, STOP
Constructor and Description |
---|
CouchbaseNodeImpl() |
Modifier and Type | Method and Description |
---|---|
void |
bucketCreate(java.lang.String bucketName,
java.lang.String bucketType,
java.lang.Integer bucketPort,
java.lang.Integer bucketRamSize,
java.lang.Integer bucketReplica) |
void |
connectSensors()
For binding to the running app (e.g.
|
void |
disconnectSensors()
For disconnecting from the running app.
|
CouchbaseNodeDriver |
getDriver() |
java.lang.Class<CouchbaseNodeDriver> |
getDriverInterface() |
void |
init()
Default entity initialization, just calls
AbstractEntity.initEnrichers() . |
void |
rebalance() |
void |
serverAdd(java.lang.String serverToAdd,
java.lang.String username,
java.lang.String password) |
void |
serverAddAndRebalance(java.lang.String serverToAdd,
java.lang.String username,
java.lang.String password) |
checkModifiable, getLocalHostname, onManagementStarted, onManagementStarting, rebind, restart, start, stop, waitForEntityStart, waitForServiceUp, waitForServiceUp, waitForServiceUp, waitForServiceUp
addChild, addChild, addEnricher, addEnricher, addFeed, addGroup, addLocations, addPolicy, addPolicy, addTag, clearLocations, clearParent, config, configure, configure, configure, configure, configure, containsTag, destroy, emit, emitInternal, equals, feeds, firstLocation, getAllAttributes, getAllConfig, getAllConfigBag, getApplication, getApplicationId, getAttribute, getAttributeByNameParts, getChildren, getConfig, getConfig, getConfig, getConfig, getConfigMap, getConfigRaw, getConfigRaw, getCreationTime, getDisplayName, getEffector, getEnrichers, getEntityType, getExecutionContext, getFeedSupport, getGroups, getIconUrl, getLocalConfigBag, getLocations, getManagementContext, getManagementSupport, getMutableEntityType, getParent, getPolicies, getProxy, getProxyIfAvailable, getRebindSupport, getSubscriptionContext, getTags, hashCode, invalidateReferences, invoke, invoke, invoke, modifyAttribute, onManagementBecomingMaster, onManagementNoLongerMaster, onManagementStopped, refreshInheritedConfig, removeAllEnrichers, removeAllPolicies, removeAttribute, removeChild, removeEnricher, removeGroup, removeLocations, removePolicy, removeTag, requestPersist, resetProxy, setAttribute, setAttribute, setAttributeWithoutPublishing, setConfig, setConfig, setConfig, setConfig, setConfig, setConfig, setConfigEvenIfOwned, setConfigEvenIfOwned, setDisplayName, setManagementContext, setParent, setProxy, subscribe, subscribeToChildren, subscribeToMembers, toMetadataRecord, toString, unsubscribe, unsubscribe
getCatalogItemId, getId, getTagSupport, setCatalogItemId, tags
addChild, addChild, addEnricher, addEnricher, addFeed, addGroup, addPolicy, addPolicy, addTag, clearParent, containsTag, getApplication, getApplicationId, getAttribute, getChildren, getConfig, getConfig, getConfigRaw, getConfigRaw, getCreationTime, getDisplayName, getEnrichers, getEntityType, getGroups, getIconUrl, getId, getLocations, getParent, getPolicies, getTags, invoke, removeChild, removeEnricher, removeGroup, removePolicy, removeTag, setParent
getCatalogItemId, getTagSupport, tags
config, setConfig
setCatalogItemId
public java.lang.Class<CouchbaseNodeDriver> getDriverInterface()
getDriverInterface
in interface DriverDependentEntity
public CouchbaseNodeDriver getDriver()
getDriver
in interface DriverDependentEntity
getDriver
in class SoftwareProcessImpl
public void init()
AbstractEntity
AbstractEntity.initEnrichers()
.init
in class SoftwareProcessImpl
public void serverAdd(java.lang.String serverToAdd, java.lang.String username, java.lang.String password)
serverAdd
in interface CouchbaseNode
public void serverAddAndRebalance(java.lang.String serverToAdd, java.lang.String username, java.lang.String password)
serverAddAndRebalance
in interface CouchbaseNode
public void rebalance()
rebalance
in interface CouchbaseNode
public void connectSensors()
SoftwareProcessImpl
Implementations should be idempotent (ie tell whether sensors already connected), though the framework is pretty good about not calling when already connected. TODO improve the framework's feed system to detect duplicate additions
public void disconnectSensors()
SoftwareProcessImpl
public void bucketCreate(java.lang.String bucketName, java.lang.String bucketType, java.lang.Integer bucketPort, java.lang.Integer bucketRamSize, java.lang.Integer bucketReplica)
bucketCreate
in interface CouchbaseNode