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 |
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 |
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 |
isPackageInstall() |
boolean |
isRiakOnPath() |
boolean |
isRunning()
Whether the entity components have started.
|
void |
joinCluster(java.lang.String nodeName) |
void |
launch() |
void |
leaveCluster() |
java.lang.Integer |
maxOpenFiles() |
void |
preInstall()
Implement this method in child classes to add some pre-install behavior
|
void |
recoverFailedNode(java.lang.String nodeName) |
void |
removeNode(java.lang.String nodeName) |
void |
stop()
Performs software stop (or queues tasks to do this)
|
checkNoHostnameBug, copyInstallResources, copyResource, copyResource, execute, execute, execute, getAddress, getExpandedInstallDir, getHostname, getInstallDir, getLocation, getMachine, getPortsUsed, getRunDir, getSubnetAddress, getSubnetHostname, runPostInstallCommand, runPostLaunchCommand, runPreInstallCommand, runPreLaunchCommand, setExpandedInstallDir, setupcopyPreInstallResources, copyResource, copyResource, copyResource, copyResource, copyResource, copyResource, copyResource, copyRuntimeResources, copyTemplate, copyTemplate, copyTemplate, getResource, getResourceAsString, getVersion, 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 boolean isPackageInstall()
public boolean isRiakOnPath()
public 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 removeNode(java.lang.String nodeName)
removeNode in interface RiakNodeDriverpublic void bucketTypeCreate(java.lang.String bucketTypeName,
java.lang.String bucketTypeProperties)
bucketTypeCreate in interface RiakNodeDriverpublic java.util.List<java.lang.String> bucketTypeList()
bucketTypeList in interface RiakNodeDriverpublic java.util.List<java.lang.String> bucketTypeStatus(java.lang.String bucketTypeName)
bucketTypeStatus in interface RiakNodeDriverpublic void bucketTypeUpdate(java.lang.String bucketTypeName,
java.lang.String bucketTypeProperties)
bucketTypeUpdate in interface RiakNodeDriverpublic void bucketTypeActivate(java.lang.String bucketTypeName)
bucketTypeActivate in interface RiakNodeDriverpublic void recoverFailedNode(java.lang.String nodeName)
recoverFailedNode in interface RiakNodeDriverpublic java.lang.String getOsMajorVersion()
getOsMajorVersion in interface RiakNodeDriverpublic java.lang.Integer maxOpenFiles()