RiakNodeImpl (Apache Brooklyn)

java.lang.Object
- brooklyn.basic.AbstractBrooklynObject
- - brooklyn.entity.basic.AbstractEntity
  - - brooklyn.entity.basic.SoftwareProcessImpl
    - - brooklyn.entity.nosql.riak.RiakNodeImpl

All Implemented Interfaces:

BrooklynObject, BrooklynObjectInternal, EntityInternal, EntityLocal, SoftwareProcess, DriverDependentEntity, Entity, RiakNode, Rebindable, Configurable, Identifiable, Startable
```
public class RiakNodeImpl
extends SoftwareProcessImpl
implements RiakNode
```

Nested Class Summary
- Nested classes/interfaces inherited from interface brooklyn.entity.basic.SoftwareProcess
  SoftwareProcess.ChildStartableMode, SoftwareProcess.RestartSoftwareParameters, SoftwareProcess.StopSoftwareParameters
- Nested classes/interfaces inherited from interface brooklyn.basic.BrooklynObject
  BrooklynObject.TagSupport
- Nested classes/interfaces inherited from interface brooklyn.entity.trait.Configurable
  Configurable.ConfigurationSupport
- Nested classes/interfaces inherited from interface brooklyn.entity.trait.Startable
  Startable.RestartEffectorBody, Startable.StartEffectorBody, Startable.StopEffectorBody
- Nested classes/interfaces inherited from interface brooklyn.entity.basic.EntityInternal
  EntityInternal.FeedSupport
- Nested classes/interfaces inherited from interface brooklyn.basic.BrooklynObjectInternal
  BrooklynObjectInternal.ConfigurationSupportInternal

Field Summary
- Fields inherited from class brooklyn.entity.basic.AbstractEntity
  CHILD_ADDED, CHILD_REMOVED, EFFECTOR_ADDED, EFFECTOR_CHANGED, EFFECTOR_REMOVED, LOCATION_ADDED, LOCATION_REMOVED, POLICY_ADDED, POLICY_REMOVED, SENSOR_ADDED, SENSOR_REMOVED
- Fields inherited from interface brooklyn.entity.nosql.riak.RiakNode
  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_SOLR_JMX_PORT, SEARCH_SOLR_PORT, SUGGESTED_VERSION, SYS_PROCESS_COUNT, VNODE_GETS, VNODE_GETS_TOTAL, VNODE_PUTS, VNODE_PUTS_TOTAL
- Fields inherited from interface brooklyn.entity.basic.SoftwareProcess
  ADDRESS, CHILDREN_STARTABLE_MODE, CUSTOMIZE_LATCH, DOWNLOAD_ADDON_URLS, DOWNLOAD_URL, 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
- Fields inherited from interface brooklyn.entity.trait.Startable
  RESTART, SERVICE_UP, START, STOP

Constructor Summary

Constructors
Constructor and Description

RiakNodeImpl()

Constructors
Constructor and Description
`RiakNodeImpl()`

Method Summary

Methods
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, just calls `AbstractEntity.initEnrichers()`.
`boolean`	`isPackageDownloadUrlProvided()`
`void`	`joinCluster(java.lang.String nodeName)`
`void`	`leaveCluster()`
`void`	`recoverFailedNode(java.lang.String nodeName)`
`void`	`removeNode(java.lang.String nodeName)`

Methods inherited from class brooklyn.entity.basic.SoftwareProcessImpl
checkModifiable, getLocalHostname, onManagementStarted, onManagementStarting, rebind, restart, start, stop, waitForEntityStart, waitForServiceUp, waitForServiceUp, waitForServiceUp, waitForServiceUp

Methods inherited from class brooklyn.entity.basic.AbstractEntity
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

Methods inherited from class brooklyn.basic.AbstractBrooklynObject
getCatalogItemId, getId, getTagSupport, setCatalogItemId, tags

Methods inherited from class java.lang.Object
getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface brooklyn.entity.Entity
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

Methods inherited from interface brooklyn.basic.BrooklynObject
getCatalogItemId, getTagSupport, tags

Methods inherited from interface brooklyn.entity.trait.Configurable
config, setConfig

Methods inherited from interface brooklyn.entity.trait.Startable
restart, start, stop

Methods inherited from interface brooklyn.basic.BrooklynObjectInternal
setCatalogItemId

- 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, just 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
  - 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

Class RiakNodeImpl

Nested Class Summary

Nested classes/interfaces inherited from interface brooklyn.entity.basic.SoftwareProcess

Nested classes/interfaces inherited from interface brooklyn.basic.BrooklynObject

Nested classes/interfaces inherited from interface brooklyn.entity.trait.Configurable

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

Nested classes/interfaces inherited from interface brooklyn.entity.basic.EntityInternal

Nested classes/interfaces inherited from interface brooklyn.basic.BrooklynObjectInternal

Field Summary

Fields inherited from class brooklyn.entity.basic.AbstractEntity

Fields inherited from interface brooklyn.entity.nosql.riak.RiakNode

Fields inherited from interface brooklyn.entity.basic.SoftwareProcess

Fields inherited from interface brooklyn.entity.trait.Startable

Constructor Summary

Method Summary

Methods inherited from class brooklyn.entity.basic.SoftwareProcessImpl

Methods inherited from class brooklyn.entity.basic.AbstractEntity

Methods inherited from class brooklyn.basic.AbstractBrooklynObject

Methods inherited from class java.lang.Object

Methods inherited from interface brooklyn.entity.Entity

Methods inherited from interface brooklyn.basic.BrooklynObject

Methods inherited from interface brooklyn.entity.trait.Configurable

Methods inherited from interface brooklyn.entity.trait.Startable

Methods inherited from interface brooklyn.basic.BrooklynObjectInternal

Constructor Detail

RiakNodeImpl

Method Detail

getDriver

getDriverInterface

init

isPackageDownloadUrlProvided

connectSensors

disconnectSensors

joinCluster

leaveCluster

removeNode

bucketTypeCreate

bucketTypeList

bucketTypeStatus

bucketTypeUpdate

bucketTypeActivate

recoverFailedNode

getRiakWebPort

getRiakPbPort

getHandoffListenerPort

getEpmdListenerPort

getErlangPortRangeStart

getErlangPortRangeEnd

getSearchSolrPort

getSearchSolrJmxPort

getMajorVersion

getFullVersion

getOsMajorVersion