org.apache.brooklyn.entity.nosql.couchbase

Class CouchbaseNodeImpl

java.lang.Object

org.apache.brooklyn.core.objs.AbstractBrooklynObject

org.apache.brooklyn.core.entity.AbstractEntity

org.apache.brooklyn.entity.software.base.SoftwareProcessImpl

org.apache.brooklyn.entity.nosql.couchbase.CouchbaseNodeImpl

All Implemented Interfaces:

DriverDependentEntity, Entity, EntityLocal, Rebindable, BrooklynObject, Configurable, Identifiable, EntityInternal, Startable, BrooklynObjectInternal, CouchbaseNode, SoftwareProcess

public class CouchbaseNodeImpl
extends SoftwareProcessImpl
implements CouchbaseNode

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.brooklyn.entity.software.base.SoftwareProcessImpl

SoftwareProcessImpl.ServiceNotUpDiagnosticsCollector, SoftwareProcessImpl.UpdatingNotUpFromServiceProcessIsRunning

Nested classes/interfaces inherited from class org.apache.brooklyn.core.entity.AbstractEntity

AbstractEntity.BasicConfigurationSupport, AbstractEntity.BasicEnricherSupport, AbstractEntity.BasicGroupSupport, AbstractEntity.BasicPolicySupport, AbstractEntity.BasicSensorSupport, AbstractEntity.BasicSubscriptionSupport

Nested classes/interfaces inherited from interface org.apache.brooklyn.entity.nosql.couchbase.CouchbaseNode

CouchbaseNode.MainUri

Nested classes/interfaces inherited from interface org.apache.brooklyn.entity.software.base.SoftwareProcess

SoftwareProcess.ChildStartableMode, SoftwareProcess.RestartSoftwareParameters, SoftwareProcess.StopSoftwareParameters

Nested classes/interfaces inherited from interface org.apache.brooklyn.api.entity.Entity

Entity.AdjunctSupport<T extends EntityAdjunct>, Entity.EnricherSupport, Entity.GroupSupport, Entity.PolicySupport, Entity.SensorSupport

Nested classes/interfaces inherited from interface org.apache.brooklyn.api.objs.BrooklynObject

BrooklynObject.RelationSupport<T extends BrooklynObject>, BrooklynObject.SubscriptionSupport, BrooklynObject.TagSupport

Nested classes/interfaces inherited from interface org.apache.brooklyn.api.objs.Configurable

Configurable.ConfigurationSupport

Nested classes/interfaces inherited from interface org.apache.brooklyn.core.entity.trait.Startable

Startable.RestartEffectorBody, Startable.StartEffectorBody, Startable.StopEffectorBody

Nested classes/interfaces inherited from interface org.apache.brooklyn.core.entity.EntityInternal

EntityInternal.EnricherSupportInternal, EntityInternal.EntitySubscriptionSupportInternal, EntityInternal.FeedSupport, EntityInternal.GroupSupportInternal, EntityInternal.PolicySupportInternal, EntityInternal.SensorSupportInternal

Nested classes/interfaces inherited from interface org.apache.brooklyn.core.objs.BrooklynObjectInternal

BrooklynObjectInternal.ConfigurationSupportInternal, BrooklynObjectInternal.RelationSupportInternal<T extends BrooklynObject>, BrooklynObjectInternal.SubscriptionSupportInternal

Field Summary

Fields inherited from class org.apache.brooklyn.core.entity.AbstractEntity

APPLICATION_ID, CATALOG_ID, CHILD_ADDED, CHILD_REMOVED, CONFIG_KEY_ADDED, CONFIG_KEY_REMOVED, DEFAULT_DISPLAY_NAME, EFFECTOR_ADDED, EFFECTOR_CHANGED, EFFECTOR_REMOVED, ENTITY_ID, GROUP_ADDED, GROUP_REMOVED, LOCATION_ADDED, LOCATION_REMOVED, POLICY_ADDED, POLICY_REMOVED, SENSOR_ADDED, SENSOR_REMOVED

Fields inherited from interface org.apache.brooklyn.entity.nosql.couchbase.CouchbaseNode

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

Fields inherited from interface org.apache.brooklyn.entity.software.base.SoftwareProcess

ADD_OPEN_INBOUND_PORTS_EFFECTOR, ADDRESS, ARCHIVE_DIRECTORY_NAME_FORMAT, CHILDREN_STARTABLE_MODE, CUSTOMIZE_FILES, CUSTOMIZE_LATCH, CUSTOMIZE_TEMPLATES, DONT_REQUIRE_TTY_FOR_SUDO, DOWNLOAD_ADDON_URLS, ENTITY_STARTED, EXPANDED_INSTALL_DIR, HOSTNAME, INBOUND_PORTS_AUTO_INFER, INBOUND_PORTS_CONFIG_REGEX, INSTALL_DIR, INSTALL_FILES, INSTALL_LATCH, INSTALL_RESOURCES_LATCH, INSTALL_TEMPLATES, INSTALL_UNIQUE_LABEL, LAUNCH_LATCH, LIFECYCLE_EFFECTOR_TASKS, MAXIMUM_REBIND_SENSOR_CONNECT_DELAY, OPEN_IPTABLES, PID_FILE, POST_CUSTOMIZE_COMMAND, POST_INSTALL_COMMAND, POST_LAUNCH_COMMAND, PRE_CUSTOMIZE_COMMAND, PRE_INSTALL_COMMAND, PRE_INSTALL_FILES, PRE_INSTALL_TEMPLATES, PRE_LAUNCH_COMMAND, PROVISIONING_LOCATION, PROVISIONING_PROPERTIES, REQUIRED_OPEN_LOGIN_PORTS, RETRIEVE_USAGE_METRICS, RUN_DIR, RUNTIME_FILES, RUNTIME_RESOURCES_LATCH, RUNTIME_TEMPLATES, SERVICE_PROCESS_IS_RUNNING, SERVICE_PROCESS_IS_RUNNING_POLL_PERIOD, SERVICE_STATE_ACTUAL, SERVICE_STATE_EXPECTED, SETUP_LATCH, SHELL_ENVIRONMENT, SKIP_ENTITY_START_IF_RUNNING, SKIP_INSTALLATION, START_LATCH, START_TIMEOUT, STOP_IPTABLES, STOP_LATCH, SUBNET_ADDRESS, SUBNET_HOSTNAME, TEMPLATE_SUBSTITUTIONS

Fields inherited from interface org.apache.brooklyn.core.entity.trait.Startable

RESTART, SERVICE_UP, START, STOP

Constructor Summary

Constructors

Constructor and Description
CouchbaseNodeImpl()

Method Summary

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 sets ID sensors and 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)

Methods inherited from class org.apache.brooklyn.entity.software.base.SoftwareProcessImpl

onManagementStarted, onManagementStarting, populateServiceNotUpDiagnostics, rebind, restart, start, stop, waitForEntityStart, waitForServiceUp, waitForServiceUp, waitForServiceUp, waitForServiceUp

Methods inherited from class org.apache.brooklyn.core.entity.AbstractEntity

addChild, addChild, addFeed, addLocations, addLocationsWithoutPublishing, clearLocations, clearParent, config, configure, configure, destroy, enrichers, equals, feeds, firstLocation, getApplication, getApplicationId, getAttribute, getChildren, getConfig, getConfig, getCreationTime, getDisplayName, getEffector, getEntityType, getExecutionContext, getIconUrl, getLocations, getManagementContext, getManagementSupport, getMutableEntityType, getParent, getProxy, getProxyIfAvailable, getRebindSupport, groups, hashCode, invalidateReferences, invoke, invoke, invoke, onManagementBecomingMaster, onManagementNoLongerMaster, onManagementStopped, policies, relations, removeChild, removeLocations, requestPersist, resetProxy, sensors, setConfigEvenIfOwned, setConfigEvenIfOwned, setDisplayName, setManagementContext, setParent, setProxy, subscriptions, toMetadataRecord, toString

Methods inherited from class org.apache.brooklyn.core.objs.AbstractBrooklynObject

addSearchPath, getCatalogItemId, getCatalogItemIdSearchPath, getId, setCatalogItemId, setCatalogItemIdAndSearchPath, stackCatalogItemId, tags

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.brooklyn.entity.software.base.SoftwareProcess

populateServiceNotUpDiagnostics

Methods inherited from interface org.apache.brooklyn.api.entity.Entity

addChild, addChild, addFeed, clearParent, enrichers, getApplication, getApplicationId, getAttribute, getChildren, getConfig, getCreationTime, getDisplayName, getEntityType, getIconUrl, getId, getLocations, getParent, groups, invoke, policies, relations, removeChild, sensors, setDisplayName, setParent

Methods inherited from interface org.apache.brooklyn.api.objs.BrooklynObject

getCatalogItemId, getCatalogItemIdSearchPath, subscriptions, tags

Methods inherited from interface org.apache.brooklyn.api.objs.Configurable

config, getConfig

Methods inherited from interface org.apache.brooklyn.core.entity.trait.Startable

restart, start, stop

Methods inherited from interface org.apache.brooklyn.core.objs.BrooklynObjectInternal

addSearchPath, setCatalogItemId, setCatalogItemIdAndSearchPath, stackCatalogItemId

Constructor Detail

CouchbaseNodeImpl

public CouchbaseNodeImpl()

Method Detail

getDriverInterface

public java.lang.Class<CouchbaseNodeDriver> getDriverInterface()

Specified by:

getDriverInterface in interface DriverDependentEntity

getDriver

public CouchbaseNodeDriver getDriver()

Specified by:

getDriver in interface DriverDependentEntity

Overrides:

getDriver in class SoftwareProcessImpl

init

public void init()

Description copied from class: AbstractEntity

Default entity initialization sets ID sensors and calls AbstractEntity.initEnrichers().

Overrides:

init in class SoftwareProcessImpl

serverAdd

public void serverAdd(java.lang.String serverToAdd,
                      java.lang.String username,
                      java.lang.String password)

Specified by:

serverAdd in interface CouchbaseNode

serverAddAndRebalance

public void serverAddAndRebalance(java.lang.String serverToAdd,
                                  java.lang.String username,
                                  java.lang.String password)

Specified by:

serverAddAndRebalance in interface CouchbaseNode

rebalance

public void rebalance()

Specified by:

rebalance in interface CouchbaseNode

connectSensors

public void connectSensors()

Description copied from class: SoftwareProcessImpl

For binding to the running app (e.g. connecting sensors to registry). Will be called on start() and on rebind().

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

disconnectSensors

public void disconnectSensors()

Description copied from class: SoftwareProcessImpl

For disconnecting from the running app. Will be called on stop.

bucketCreate

public void bucketCreate(java.lang.String bucketName,
                         java.lang.String bucketType,
                         java.lang.Integer bucketPort,
                         java.lang.Integer bucketRamSize,
                         java.lang.Integer bucketReplica)

Specified by:

bucketCreate in interface CouchbaseNode