public class RiakNodeSshDriver extends AbstractSoftwareProcessSshDriver implements RiakNodeDriver
CHECK_RUNNING, CUSTOMIZING, DEBUG, IGNORE_ENTITY_SSH_FLAGS, INSTALL_INCOMPLETE, INSTALLING, KILLING, LAUNCHING, log, logSsh, NON_STANDARD_LAYOUT, PID_FILENAME, PROCESS_OWNER, RESTARTING, STOPPING, USE_PID_FILE, VALID_FLAGS
Constructor and Description |
---|
RiakNodeSshDriver(RiakNodeImpl entity,
SshMachineLocation machine) |
Modifier and Type | Method and Description |
---|---|
void |
commitCluster() |
void |
customize() |
RiakNodeImpl |
getEntity()
The entity whose components we are controlling.
|
java.lang.String |
getOsMajorVersion() |
java.lang.String |
getRiakEtcDir() |
java.util.Map<java.lang.String,java.lang.String> |
getShellEnvironment()
The environment variables to be set when executing the commands (for install, run, check running, etc).
|
void |
install() |
boolean |
isRunning()
Whether the entity components have started.
|
void |
joinCluster(java.lang.String nodeName) |
void |
launch() |
void |
leaveCluster() |
void |
preInstall()
Implement this method in child classes to add some post-launch behavior
|
void |
recoverFailedNode(java.lang.String nodeName) |
void |
stop()
Performs software stop (or queues tasks to do this)
|
copyInstallResources, copyResource, copyResource, copyResource, copyResource, copyResource, copyResource, copyResource, copyResource, copyResource, copyRuntimeResources, copyTemplate, copyTemplate, copyTemplate, execute, execute, execute, getAddress, getDownloadFilename, getDownloadFileSuffix, getExpandedInstallDir, getHostname, getInstallDir, getLocation, getMachine, getPortsUsed, getRunDir, getSubnetAddress, getSubnetHostname, getVersion, runPostInstallCommand, runPostLaunchCommand, runPreInstallCommand, runPreLaunchCommand, setExpandedInstallDir, setup
getResource, getResourceAsString, kill, postLaunch, processTemplate, processTemplate, processTemplate, processTemplate, processTemplateContents, processTemplateContents, rebind, restart, start
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
kill, rebind, restart, start
getLocation
public RiakNodeSshDriver(RiakNodeImpl entity, SshMachineLocation machine)
public RiakNodeImpl getEntity()
SoftwareProcessDriver
getEntity
in interface SoftwareProcessDriver
getEntity
in interface EntityDriver
getEntity
in class AbstractSoftwareProcessDriver
public java.util.Map<java.lang.String,java.lang.String> getShellEnvironment()
AbstractSoftwareProcessSshDriver
getShellEnvironment
in class AbstractSoftwareProcessSshDriver
SoftwareProcess.SHELL_ENVIRONMENT
public void preInstall()
AbstractSoftwareProcessDriver
preInstall
in class AbstractSoftwareProcessDriver
public void install()
install
in class AbstractSoftwareProcessDriver
public void customize()
customize
in class AbstractSoftwareProcessDriver
public void launch()
launch
in class AbstractSoftwareProcessDriver
public void stop()
SoftwareProcessDriver
stop
in interface SoftwareProcessDriver
stop
in class AbstractSoftwareProcessDriver
Startable.stop()
public boolean isRunning()
SoftwareProcessDriver
isRunning
in interface SoftwareProcessDriver
public java.lang.String getRiakEtcDir()
getRiakEtcDir
in interface RiakNodeDriver
public void joinCluster(java.lang.String nodeName)
joinCluster
in interface RiakNodeDriver
public void leaveCluster()
leaveCluster
in interface RiakNodeDriver
public void commitCluster()
commitCluster
in interface RiakNodeDriver
public void recoverFailedNode(java.lang.String nodeName)
recoverFailedNode
in interface RiakNodeDriver
public java.lang.String getOsMajorVersion()
getOsMajorVersion
in interface RiakNodeDriver