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, setup
copyPreInstallResources, copyResource, copyResource, copyResource, copyResource, copyResource, copyResource, copyResource, copyRuntimeResources, copyTemplate, copyTemplate, copyTemplate, getResource, getResourceAsString, getVersion, 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 boolean isPackageInstall()
public boolean isRiakOnPath()
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 removeNode(java.lang.String nodeName)
removeNode
in interface RiakNodeDriver
public void bucketTypeCreate(java.lang.String bucketTypeName, java.lang.String bucketTypeProperties)
bucketTypeCreate
in interface RiakNodeDriver
public java.util.List<java.lang.String> bucketTypeList()
bucketTypeList
in interface RiakNodeDriver
public java.util.List<java.lang.String> bucketTypeStatus(java.lang.String bucketTypeName)
bucketTypeStatus
in interface RiakNodeDriver
public void bucketTypeUpdate(java.lang.String bucketTypeName, java.lang.String bucketTypeProperties)
bucketTypeUpdate
in interface RiakNodeDriver
public void bucketTypeActivate(java.lang.String bucketTypeName)
bucketTypeActivate
in interface RiakNodeDriver
public void recoverFailedNode(java.lang.String nodeName)
recoverFailedNode
in interface RiakNodeDriver
public java.lang.String getOsMajorVersion()
getOsMajorVersion
in interface RiakNodeDriver
public java.lang.Integer maxOpenFiles()