public class ZooKeeperSshDriver extends JavaSoftwareProcessSshDriver implements ZooKeeperDriver
Modifier and Type | Class and Description |
---|---|
static class |
ZooKeeperSshDriver.ZooKeeperServerConfig |
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 |
---|
ZooKeeperSshDriver(ZooKeeperNodeImpl entity,
SshMachineLocation machine) |
Modifier and Type | Method and Description |
---|---|
void |
customize()
Implementations should fail if the return code is non-zero, by throwing some appropriate exception.
|
java.lang.String |
getPidFile() |
java.lang.Integer |
getZooKeeperPort() |
java.util.List<ZooKeeperSshDriver.ZooKeeperServerConfig> |
getZookeeperServers() |
void |
install()
Implementations should fail if the return code is non-zero, by throwing some appropriate exception.
|
boolean |
isRunning()
Whether the entity components have started.
|
void |
launch()
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, getShellEnvironment, installJava, installJmxSupport, isJmxEnabled, isJmxSslEnabled, setup
checkNoHostnameBug, copyCustomizeResources, copyInstallResources, copyPreInstallResources, copyResource, copyResource, execute, execute, execute, getAddress, getHostname, getLocation, getMachine, getPortsUsed, getSubnetAddress, getSubnetHostname, prepare, runPostCustomizeCommand, runPostInstallCommand, runPostLaunchCommand, runPreCustomizeCommand, runPreInstallCommand, runPreLaunchCommand
copyResource, copyResource, copyResource, copyResource, copyResource, copyResource, copyResource, copyTemplate, copyTemplate, copyTemplate, getArchiveNameFormat, getEntity, 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
isJmxEnabled
getEntity, kill, rebind, restart, start
getLocation
public ZooKeeperSshDriver(ZooKeeperNodeImpl entity, SshMachineLocation machine)
public java.util.List<ZooKeeperSshDriver.ZooKeeperServerConfig> getZookeeperServers() throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
java.util.concurrent.ExecutionException
java.lang.InterruptedException
public java.lang.Integer getZooKeeperPort()
getZooKeeperPort
in interface ZooKeeperDriver
public boolean isRunning()
SoftwareProcessDriver
isRunning
in interface SoftwareProcessDriver
public void stop()
SoftwareProcessDriver
stop
in interface SoftwareProcessDriver
stop
in class AbstractSoftwareProcessDriver
Startable.stop()
public void install()
AbstractSoftwareProcessDriver
install
in class AbstractSoftwareProcessDriver
public void customize()
AbstractSoftwareProcessDriver
customize
in class AbstractSoftwareProcessDriver
public java.lang.String getPidFile()
public void launch()
AbstractSoftwareProcessDriver
launch
in class AbstractSoftwareProcessDriver