Brooklyn

brooklyn.entity.nosql.cassandra
[Java] Class CassandraNodeSshDriver

java.lang.Object
  brooklyn.entity.basic.AbstractSoftwareProcessDriver
      brooklyn.entity.basic.AbstractSoftwareProcessSshDriver
          brooklyn.entity.java.JavaSoftwareProcessSshDriver
              brooklyn.entity.nosql.cassandra.CassandraNodeSshDriver
All Implemented Interfaces:
CassandraNodeDriver

public class CassandraNodeSshDriver
extends JavaSoftwareProcessSshDriver

Start a CassandraNode in a Location accessible over ssh.


Field Summary
 
Fields inherited from class JavaSoftwareProcessSshDriver
KEY_VAL_OPT_PREFIXES, MUTUALLY_EXCLUSIVE_OPTS, log
 
Fields inherited from class AbstractSoftwareProcessSshDriver
BROOKLYN_HOME_DIR, CHECK_RUNNING, CUSTOMIZING, DEFAULT_INSTALL_BASEDIR, DEFAULT_RUN_BASEDIR, IGNORE_ENTITY_SSH_FLAGS, INSTALLING, KILLING, LAUNCHING, NO_VERSION_INFO, PID_FILENAME, RESTARTING, STOPPING, USE_PID_FILE, log, logSsh
 
Fields inherited from class AbstractSoftwareProcessDriver
entity, location, resource
 
Constructor Summary
CassandraNodeSshDriver(CassandraNodeImpl entity, SshMachineLocation machine)

 
Method Summary
void customize()

java.lang.String getCassandraConfigFileName()

java.lang.String getCassandraConfigTemplateUrl()

java.lang.String getCassandraRackdcConfigFileName()

java.lang.String getCassandraRackdcConfigTemplateUrl()

java.lang.String getClusterName()

protected java.util.Map getCustomJavaSystemProperties()

java.lang.String getEndpointSnitchName()

java.lang.Integer getGossipPort()

protected java.lang.String getLogFileLocation()

java.lang.String getMirrorUrl()

java.lang.String getPidFile()

java.util.Set getPortsUsed()

java.util.Map getShellEnvironment()

java.lang.Integer getSslGossipPort()

java.lang.Integer getThriftPort()

void install()

boolean isClustered()

boolean isRunning()

void launch()

void stop()

 
Methods inherited from class JavaSoftwareProcessSshDriver
checkJavaHostnameBug, getCustomJavaConfigOptions, getCustomJavaSystemProperties, getJavaOpts, getJavaSystemProperties, getJmxContext, getJmxJavaConfigOptions, getJmxJavaSystemProperties, getJmxPort, getLogFileLocation, getRmiPort, getRmiRegistryPort, getRmiServerPort, getShellEnvironment, installJava, installJmxSupport, isJmxEnabled, isJmxSslEnabled, start
 
Methods inherited from class AbstractSoftwareProcessSshDriver
copyFile, copyFile, copyFile, copyResource, copyResource, copyResource, copyResources, copyTemplate, copyTemplate, copyTemplate, copyTemplates, execute, execute, getAddress, getDefaultVersion, getDownloadFileSuffix, getDownloadFilename, getEntityVersionLabel, getEntityVersionLabel, getHostname, getInstallDir, getLocation, getMachine, getPortsUsed, getRunDir, getShellEnvironment, getSshFlags, getVersion, newScript, newScript
 
Methods inherited from class AbstractSoftwareProcessDriver
customize, doFullStartOnRestart, getEntity, getLocation, getResource, getResourceAsString, install, kill, launch, postLaunch, processTemplate, processTemplate, processTemplate, processTemplate, processTemplateContents, processTemplateContents, rebind, restart, start, stop, waitForConfigKey
 

Constructor Detail

CassandraNodeSshDriver

public CassandraNodeSshDriver(CassandraNodeImpl entity, SshMachineLocation machine)


 
Method Detail

customize

@Override
public void customize()


getCassandraConfigFileName

@Override
public java.lang.String getCassandraConfigFileName()


getCassandraConfigTemplateUrl

@Override
public java.lang.String getCassandraConfigTemplateUrl()


getCassandraRackdcConfigFileName

public java.lang.String getCassandraRackdcConfigFileName()


getCassandraRackdcConfigTemplateUrl

public java.lang.String getCassandraRackdcConfigTemplateUrl()


getClusterName

@Override
public java.lang.String getClusterName()


getCustomJavaSystemProperties

public Map getShellEnvironment() {
protected java.util.Map getCustomJavaSystemProperties()


getEndpointSnitchName

public java.lang.String getEndpointSnitchName()


getGossipPort

@Override
public java.lang.Integer getGossipPort()


getLogFileLocation

@Override
protected java.lang.String getLogFileLocation()


getMirrorUrl

public java.lang.String getMirrorUrl()


getPidFile

public java.lang.String getPidFile()


getPortsUsed

public java.util.Set getPortsUsed()


getShellEnvironment

public java.util.Map getShellEnvironment()


getSslGossipPort

@Override
public java.lang.Integer getSslGossipPort()


getThriftPort

@Override
public java.lang.Integer getThriftPort()


install

@Override
public void install()


isClustered

@Override
public boolean isClustered()


isRunning

public boolean isRunning()


launch

"cluster "+getClusterName()+", " +
public void launch()


stop

.put("cassandra.confing", getCassandraConfigFileName())
public void stop()


 

Brooklyn Multi-Cloud Application Management Platform
brooklyncentral.github.com. Apache License. © 2012.