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() |
java.lang.String |
getPidFile() |
java.lang.Integer |
getZooKeeperPort() |
java.util.List<ZooKeeperSshDriver.ZooKeeperServerConfig> |
getZookeeperServers() |
void |
install() |
boolean |
isRunning()
Whether the entity components have started.
|
void |
launch() |
void |
preInstall()
Implement this method in child classes to add some pre-install behavior
|
void |
stop()
Performs software stop (or queues tasks to do this)
|
checkJavaHostnameBug, copyRuntimeResources, getJavaOpts, getJmxContext, getJmxPort, getRmiRegistryPort, getShellEnvironment, installJava, installJmxSupport, isJmxEnabled, isJmxSslEnabled, setup
checkNoHostnameBug, copyInstallResources, copyResource, copyResource, execute, execute, execute, getAddress, getExpandedInstallDir, getHostname, getInstallDir, getLocation, getMachine, getPortsUsed, getRunDir, getSubnetAddress, getSubnetHostname, runPostInstallCommand, runPostLaunchCommand, runPreInstallCommand, runPreLaunchCommand, setExpandedInstallDir
copyPreInstallResources, copyResource, copyResource, copyResource, copyResource, copyResource, copyResource, copyResource, copyTemplate, copyTemplate, copyTemplate, getEntity, getResource, getResourceAsString, getVersion, kill, postLaunch, processTemplate, processTemplate, processTemplate, processTemplate, processTemplateContents, processTemplateContents, rebind, restart, 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 preInstall()
AbstractSoftwareProcessDriver
preInstall
in class AbstractSoftwareProcessDriver
public void install()
install
in class AbstractSoftwareProcessDriver
public void customize()
customize
in class AbstractSoftwareProcessDriver
public java.lang.String getPidFile()
public void launch()
launch
in class AbstractSoftwareProcessDriver