org.apache.brooklyn.entity.nosql.riak

Class RiakNodeImpl

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.riak.RiakNodeImpl

All Implemented Interfaces:

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

public class RiakNodeImpl
extends SoftwareProcessImpl
implements RiakNode

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.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.riak.RiakNode

ARCHIVE_DIRECTORY_NAME_FORMAT, CONFIGURE_INTERNAL_NETWORKING, COORD_REDIRS_TOTAL, DOWNLOAD_URL_DEBIAN, DOWNLOAD_URL_MAC, DOWNLOAD_URL_RHEL_CENTOS, DOWNLOAD_URL_UBUNTU, EPMD_LISTENER_PORT, ERLANG_PORT_RANGE_END, ERLANG_PORT_RANGE_START, HANDOFF_LISTENER_PORT, JOIN_RIAK_CLUSTER, LEAVE_RIAK_CLUSTER, MEMORY_PROCESSES_USED, NODE_GETS, NODE_GETS_TOTAL, NODE_OPS, NODE_OPS_TOTAL, NODE_PUTS, NODE_PUTS_TOTAL, ONE_MINUTE_SENSORS, OPTIMIZE_HOST_NETWORKING, PBC_ACTIVE, PBC_CONNECTS, READ_REPAIRS_TOTAL, REMOVE_FROM_CLUSTER, RIAK_APP_CONFIG_TEMPLATE_URL, RIAK_CONF_ADDITIONAL_CONTENT, RIAK_CONF_TEMPLATE_URL_LINUX, RIAK_CONF_TEMPLATE_URL_MAC, RIAK_CONSISTENT_GET_TIME_MEAN, RIAK_CONSISTENT_PUT_TIME_MEAN, RIAK_CONSOLE_URI, RIAK_MAX_OPEN_FILES, RIAK_NODE_GET_FSM_TIME_MEAN, RIAK_NODE_HAS_JOINED_CLUSTER, RIAK_NODE_NAME, RIAK_NODE_PUT_FSM_TIME_MEAN, RIAK_OBJECT_COUNTER_MERGE_TIME_MEAN, RIAK_OBJECT_MAP_MERGE_TIME_MEAN, RIAK_OBJECT_SET_MERGE_TIME_MEAN, RIAK_ON_PATH, RIAK_PACKAGE_INSTALL, RIAK_PB_PORT, RIAK_VM_ARGS_TEMPLATE_URL, RIAK_WEB_PORT, RING_MEMBERS, SEARCH_ENABLED, SEARCH_SOLR_JMX_PORT, SEARCH_SOLR_PORT, SUGGESTED_VERSION, SYS_PROCESS_COUNT, USE_HTTP_MONITORING, VNODE_GETS, VNODE_GETS_TOTAL, VNODE_PUTS, VNODE_PUTS_TOTAL

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

ADD_OPEN_INBOUND_PORTS_EFFECTOR, ADDRESS, CHILDREN_STARTABLE_MODE, CUSTOMIZE_FILES, CUSTOMIZE_LATCH, CUSTOMIZE_TEMPLATES, DONT_REQUIRE_TTY_FOR_SUDO, DOWNLOAD_ADDON_URLS, DOWNLOAD_URL, 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

Fields inherited from interface org.apache.brooklyn.entity.java.UsesJava

CHECK_JAVA_HOSTNAME_BUG, JAVA_OPTS, JAVA_SYSPROPS, JAVA_VERSION_REQUIRED

Constructor Summary

Constructors

Constructor and Description
RiakNodeImpl()

Method Summary

Modifier and Type	Method and Description
void	bucketTypeActivate(java.lang.String bucketTypeName)
void	bucketTypeCreate(java.lang.String bucketTypeName, java.lang.String bucketTypeProperties)
java.util.List<java.lang.String>	bucketTypeList()
java.util.List<java.lang.String>	bucketTypeStatus(java.lang.String bucketTypeName)
void	bucketTypeUpdate(java.lang.String bucketTypeName, java.lang.String bucketTypeProperties)
void	connectSensors() For binding to the running app (e.g.
void	disconnectSensors() For disconnecting from the running app.
RiakNodeDriver	getDriver()
java.lang.Class<RiakNodeDriver>	getDriverInterface()
java.lang.Integer	getEpmdListenerPort()
java.lang.Integer	getErlangPortRangeEnd()
java.lang.Integer	getErlangPortRangeStart()
java.lang.String	getFullVersion()
java.lang.Integer	getHandoffListenerPort()
java.lang.String	getMajorVersion()
java.lang.String	getOsMajorVersion()
java.lang.Integer	getRiakPbPort()
java.lang.Integer	getRiakWebPort()
java.lang.Integer	getSearchSolrJmxPort()
java.lang.Integer	getSearchSolrPort()
void	init() Default entity initialization sets ID sensors and calls AbstractEntity.initEnrichers().
boolean	isPackageDownloadUrlProvided()
java.lang.Boolean	isSearchEnabled()
void	joinCluster(java.lang.String nodeName)
void	leaveCluster()
void	recoverFailedNode(java.lang.String nodeName)
void	removeNode(java.lang.String nodeName)

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

RiakNodeImpl

public RiakNodeImpl()

Method Detail

getDriver

public RiakNodeDriver getDriver()

Specified by:

getDriver in interface DriverDependentEntity

Overrides:

getDriver in class SoftwareProcessImpl

getDriverInterface

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

Specified by:

getDriverInterface in interface DriverDependentEntity

init

public void init()

Description copied from class: AbstractEntity

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

Overrides:

init in class SoftwareProcessImpl

isPackageDownloadUrlProvided

public boolean isPackageDownloadUrlProvided()

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.

joinCluster

public void joinCluster(java.lang.String nodeName)

Specified by:

joinCluster in interface RiakNode

leaveCluster

public void leaveCluster()

Specified by:

leaveCluster in interface RiakNode

removeNode

public void removeNode(java.lang.String nodeName)

Specified by:

removeNode in interface RiakNode

bucketTypeCreate

public void bucketTypeCreate(java.lang.String bucketTypeName,
                             java.lang.String bucketTypeProperties)

Specified by:

bucketTypeCreate in interface RiakNode

bucketTypeList

public java.util.List<java.lang.String> bucketTypeList()

Specified by:

bucketTypeList in interface RiakNode

bucketTypeStatus

public java.util.List<java.lang.String> bucketTypeStatus(java.lang.String bucketTypeName)

Specified by:

bucketTypeStatus in interface RiakNode

bucketTypeUpdate

public void bucketTypeUpdate(java.lang.String bucketTypeName,
                             java.lang.String bucketTypeProperties)

Specified by:

bucketTypeUpdate in interface RiakNode

bucketTypeActivate

public void bucketTypeActivate(java.lang.String bucketTypeName)

Specified by:

bucketTypeActivate in interface RiakNode

recoverFailedNode

public void recoverFailedNode(java.lang.String nodeName)

Specified by:

recoverFailedNode in interface RiakNode

getRiakWebPort

public java.lang.Integer getRiakWebPort()

Specified by:

getRiakWebPort in interface RiakNode

getRiakPbPort

public java.lang.Integer getRiakPbPort()

Specified by:

getRiakPbPort in interface RiakNode

getHandoffListenerPort

public java.lang.Integer getHandoffListenerPort()

Specified by:

getHandoffListenerPort in interface RiakNode

getEpmdListenerPort

public java.lang.Integer getEpmdListenerPort()

Specified by:

getEpmdListenerPort in interface RiakNode

getErlangPortRangeStart

public java.lang.Integer getErlangPortRangeStart()

Specified by:

getErlangPortRangeStart in interface RiakNode

getErlangPortRangeEnd

public java.lang.Integer getErlangPortRangeEnd()

Specified by:

getErlangPortRangeEnd in interface RiakNode

isSearchEnabled

public java.lang.Boolean isSearchEnabled()

Specified by:

isSearchEnabled in interface RiakNode

getSearchSolrPort

public java.lang.Integer getSearchSolrPort()

Specified by:

getSearchSolrPort in interface RiakNode

getSearchSolrJmxPort

public java.lang.Integer getSearchSolrJmxPort()

Specified by:

getSearchSolrJmxPort in interface RiakNode

getMajorVersion

public java.lang.String getMajorVersion()

Specified by:

getMajorVersion in interface RiakNode

getFullVersion

public java.lang.String getFullVersion()

Specified by:

getFullVersion in interface RiakNode

getOsMajorVersion

public java.lang.String getOsMajorVersion()

Specified by:

getOsMajorVersion in interface RiakNode