public class CouchbaseNodeImpl extends SoftwareProcessImpl implements CouchbaseNode
CouchbaseNode.MainUriSoftwareProcess.ChildStartableMode, SoftwareProcess.RestartSoftwareParameters, SoftwareProcess.StopSoftwareParametersBrooklynObject.TagSupportConfigurable.ConfigurationSupportStartable.RestartEffectorBody, Startable.StartEffectorBody, Startable.StopEffectorBodyEntityInternal.FeedSupportBrooklynObjectInternal.ConfigurationSupportInternalCHILD_ADDED, CHILD_REMOVED, EFFECTOR_ADDED, EFFECTOR_CHANGED, EFFECTOR_REMOVED, LOCATION_ADDED, LOCATION_REMOVED, POLICY_ADDED, POLICY_REMOVED, SENSOR_ADDED, SENSOR_REMOVEDADD_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_ITEMSADDRESS, 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_DIRRESTART, 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, waitForServiceUpaddChild, 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, unsubscribegetCatalogItemId, getId, getTagSupport, setCatalogItemId, tagsaddChild, 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, setParentgetCatalogItemId, getTagSupport, tagsconfig, setConfigsetCatalogItemIdpublic java.lang.Class<CouchbaseNodeDriver> getDriverInterface()
getDriverInterface in interface DriverDependentEntitypublic CouchbaseNodeDriver getDriver()
getDriver in interface DriverDependentEntitygetDriver in class SoftwareProcessImplpublic void init()
AbstractEntityAbstractEntity.initEnrichers().init in class SoftwareProcessImplpublic void serverAdd(java.lang.String serverToAdd,
java.lang.String username,
java.lang.String password)
serverAdd in interface CouchbaseNodepublic void serverAddAndRebalance(java.lang.String serverToAdd,
java.lang.String username,
java.lang.String password)
serverAddAndRebalance in interface CouchbaseNodepublic void rebalance()
rebalance in interface CouchbaseNodepublic void connectSensors()
SoftwareProcessImplImplementations 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()
SoftwareProcessImplpublic 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