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, setupgetResource, getResourceAsString, kill, postLaunch, processTemplate, processTemplate, processTemplate, processTemplate, processTemplateContents, processTemplateContents, rebind, restart, startequals, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitkill, rebind, restart, startgetLocationpublic RiakNodeSshDriver(RiakNodeImpl entity, SshMachineLocation machine)
public RiakNodeImpl getEntity()
SoftwareProcessDrivergetEntity in interface SoftwareProcessDrivergetEntity in interface EntityDrivergetEntity in class AbstractSoftwareProcessDriverpublic java.util.Map<java.lang.String,java.lang.String> getShellEnvironment()
AbstractSoftwareProcessSshDrivergetShellEnvironment in class AbstractSoftwareProcessSshDriverSoftwareProcess.SHELL_ENVIRONMENTpublic void preInstall()
AbstractSoftwareProcessDriverpreInstall in class AbstractSoftwareProcessDriverpublic void install()
install in class AbstractSoftwareProcessDriverpublic void customize()
customize in class AbstractSoftwareProcessDriverpublic void launch()
launch in class AbstractSoftwareProcessDriverpublic void stop()
SoftwareProcessDriverstop in interface SoftwareProcessDriverstop in class AbstractSoftwareProcessDriverStartable.stop()public boolean isRunning()
SoftwareProcessDriverisRunning in interface SoftwareProcessDriverpublic java.lang.String getRiakEtcDir()
getRiakEtcDir in interface RiakNodeDriverpublic void joinCluster(java.lang.String nodeName)
joinCluster in interface RiakNodeDriverpublic void leaveCluster()
leaveCluster in interface RiakNodeDriverpublic void commitCluster()
commitCluster in interface RiakNodeDriverpublic void recoverFailedNode(java.lang.String nodeName)
recoverFailedNode in interface RiakNodeDriverpublic java.lang.String getOsMajorVersion()
getOsMajorVersion in interface RiakNodeDriver