public class RiakNodeSshDriver extends JavaSoftwareProcessSshDriver implements RiakNodeDriver
KEY_VAL_OPT_PREFIXES, log, MUTUALLY_EXCLUSIVE_OPTS
CHECK_RUNNING, CUSTOMIZING, DEBUG, IGNORE_ENTITY_SSH_FLAGS, INSTALL_INCOMPLETE, INSTALLING, KILLING, LAUNCHING, 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()
Implementations should fail if the return code is non-zero, by throwing some appropriate exception.
|
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()
Sets all JVM options (-X..
|
void |
install()
Implementations should fail if the return code is non-zero, by throwing some appropriate exception.
|
boolean |
isPackageInstall() |
boolean |
isRiakOnPath() |
boolean |
isRunning()
Whether the entity components have started.
|
void |
joinCluster(java.lang.String nodeName) |
void |
launch()
Implementations should fail if the return code is non-zero, by throwing some appropriate exception.
|
void |
leaveCluster() |
java.lang.Integer |
maxOpenFiles() |
void |
prepare()
Prepare the entity instance before running any commands.
|
void |
recoverFailedNode(java.lang.String nodeName) |
void |
removeNode(java.lang.String nodeName) |
void |
setup()
Implementations should fail if the return code is non-zero, by throwing some appropriate exception.
|
void |
stop()
Performs software stop (or queues tasks to do this)
|
checkJavaHostnameBug, copyRuntimeResources, getJavaOpts, getJmxContext, getJmxPort, getRmiRegistryPort, installJava, installJmxSupport, isJmxEnabled, isJmxSslEnabled
checkNoHostnameBug, copyCustomizeResources, copyInstallResources, copyPreInstallResources, copyResource, copyResource, execute, execute, execute, getAddress, getHostname, getLocation, getMachine, getPortsUsed, getSubnetAddress, getSubnetHostname, runPostCustomizeCommand, runPostInstallCommand, runPostLaunchCommand, runPreCustomizeCommand, runPreInstallCommand, runPreLaunchCommand
copyResource, copyResource, copyResource, copyResource, copyResource, copyResource, copyResource, copyTemplate, copyTemplate, copyTemplate, getArchiveNameFormat, getExpandedInstallDir, getInstallDir, getResource, getResourceAsString, getRunDir, getVersion, kill, postLaunch, preInstall, processTemplate, processTemplate, processTemplate, processTemplate, processTemplateContents, processTemplateContents, rebind, restart, setExpandedInstallDir, 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 EntityDriver
getEntity
in interface SoftwareProcessDriver
getEntity
in class AbstractSoftwareProcessDriver
public java.util.Map<java.lang.String,java.lang.String> getShellEnvironment()
JavaSoftwareProcessSshDriver
That variable is constructed from JavaSoftwareProcessSshDriver.getJavaOpts()
, then wrapped _unescaped_ in double quotes. An
error is thrown if there is an unescaped double quote in the string. All other unescaped
characters are permitted, but unless $var expansion or `command` execution is desired (although
this is not confirmed as supported) the generally caller should escape any such characters, for
example using StringEscapes.BashStringEscapes.escapeLiteralForDoubleQuotedBash(String)
.
getShellEnvironment
in class JavaSoftwareProcessSshDriver
SoftwareProcess.SHELL_ENVIRONMENT
public void prepare()
AbstractSoftwareProcessDriver
AbstractSoftwareProcessDriver.start()
.prepare
in class AbstractSoftwareProcessSshDriver
public void install()
AbstractSoftwareProcessDriver
install
in class AbstractSoftwareProcessDriver
public void customize()
AbstractSoftwareProcessDriver
customize
in class AbstractSoftwareProcessDriver
public void launch()
AbstractSoftwareProcessDriver
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 void setup()
AbstractSoftwareProcessDriver
setup
in class JavaSoftwareProcessSshDriver
public java.lang.String getOsMajorVersion()
getOsMajorVersion
in interface RiakNodeDriver
public java.lang.Integer maxOpenFiles()