public class CouchbaseNodeSshDriver extends AbstractSoftwareProcessSshDriver implements CouchbaseNodeDriver
Modifier and Type | Class and Description |
---|---|
static class |
CouchbaseNodeSshDriver.DownloadLinkSegmentComputer |
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 |
---|
CouchbaseNodeSshDriver(CouchbaseNodeImpl entity,
SshMachineLocation machine) |
Modifier and Type | Method and Description |
---|---|
void |
addReplicationRule(Entity toCluster,
java.lang.String fromBucket,
java.lang.String toBucket) |
void |
bucketCreate(java.lang.String bucketName,
java.lang.String bucketType,
java.lang.Integer bucketPort,
java.lang.Integer bucketRamSize,
java.lang.Integer bucketReplica) |
static java.lang.String |
couchbaseCli(java.lang.String cmd) |
void |
customize() |
java.lang.String |
getCommunityOrEnterprise() |
java.lang.String |
getDownloadLinkOsTagWithPrefix() |
java.lang.String |
getDownloadLinkPreVersionSeparator() |
java.lang.String |
getOsTag() |
java.lang.String |
getVersion() |
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 |
rebalance() |
void |
serverAdd(java.lang.String serverToAdd,
java.lang.String username,
java.lang.String password) |
void |
serverAddAndRebalance(java.lang.String serverToAdd,
java.lang.String username,
java.lang.String password) |
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, getShellEnvironment, getSubnetAddress, getSubnetHostname, runPostInstallCommand, runPostLaunchCommand, runPreInstallCommand, runPreLaunchCommand, setExpandedInstallDir, setup
copyPreInstallResources, copyResource, copyResource, copyResource, copyResource, copyResource, copyResource, copyResource, copyRuntimeResources, copyTemplate, copyTemplate, copyTemplate, getEntity, getResource, getResourceAsString, kill, postLaunch, processTemplate, processTemplate, processTemplate, processTemplate, processTemplateContents, processTemplateContents, rebind, restart, start
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getEntity, kill, rebind, restart, start
getLocation
public CouchbaseNodeSshDriver(CouchbaseNodeImpl entity, SshMachineLocation machine)
public static java.lang.String couchbaseCli(java.lang.String cmd)
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 boolean isRunning()
SoftwareProcessDriver
isRunning
in interface SoftwareProcessDriver
public void stop()
SoftwareProcessDriver
stop
in interface SoftwareProcessDriver
stop
in class AbstractSoftwareProcessDriver
Startable.stop()
public java.lang.String getVersion()
getVersion
in class AbstractSoftwareProcessDriver
public java.lang.String getOsTag()
getOsTag
in interface CouchbaseNodeDriver
public java.lang.String getDownloadLinkOsTagWithPrefix()
getDownloadLinkOsTagWithPrefix
in interface CouchbaseNodeDriver
public java.lang.String getDownloadLinkPreVersionSeparator()
getDownloadLinkPreVersionSeparator
in interface CouchbaseNodeDriver
public java.lang.String getCommunityOrEnterprise()
getCommunityOrEnterprise
in interface CouchbaseNodeDriver
public void rebalance()
rebalance
in interface CouchbaseNodeDriver
public void serverAdd(java.lang.String serverToAdd, java.lang.String username, java.lang.String password)
serverAdd
in interface CouchbaseNodeDriver
public void serverAddAndRebalance(java.lang.String serverToAdd, java.lang.String username, java.lang.String password)
serverAddAndRebalance
in interface CouchbaseNodeDriver
public void bucketCreate(java.lang.String bucketName, java.lang.String bucketType, java.lang.Integer bucketPort, java.lang.Integer bucketRamSize, java.lang.Integer bucketReplica)
bucketCreate
in interface CouchbaseNodeDriver
public void addReplicationRule(Entity toCluster, java.lang.String fromBucket, java.lang.String toBucket)
addReplicationRule
in interface CouchbaseNodeDriver