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, setupcopyPreInstallResources, copyResource, copyResource, copyResource, copyResource, copyResource, copyResource, copyResource, copyRuntimeResources, copyTemplate, copyTemplate, copyTemplate, getEntity, getResource, getResourceAsString, kill, postLaunch, processTemplate, processTemplate, processTemplate, processTemplate, processTemplateContents, processTemplateContents, rebind, restart, startequals, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetEntity, kill, rebind, restart, startgetLocationpublic CouchbaseNodeSshDriver(CouchbaseNodeImpl entity, SshMachineLocation machine)
public static java.lang.String couchbaseCli(java.lang.String cmd)
public void preInstall()
AbstractSoftwareProcessDriverpreInstall in class AbstractSoftwareProcessDriverpublic void install()
install in class AbstractSoftwareProcessDriverpublic void customize()
customize in class AbstractSoftwareProcessDriverpublic void launch()
launch in class AbstractSoftwareProcessDriverpublic boolean isRunning()
SoftwareProcessDriverisRunning in interface SoftwareProcessDriverpublic void stop()
SoftwareProcessDriverstop in interface SoftwareProcessDriverstop in class AbstractSoftwareProcessDriverStartable.stop()public java.lang.String getVersion()
getVersion in class AbstractSoftwareProcessDriverpublic java.lang.String getOsTag()
getOsTag in interface CouchbaseNodeDriverpublic java.lang.String getDownloadLinkOsTagWithPrefix()
getDownloadLinkOsTagWithPrefix in interface CouchbaseNodeDriverpublic java.lang.String getDownloadLinkPreVersionSeparator()
getDownloadLinkPreVersionSeparator in interface CouchbaseNodeDriverpublic java.lang.String getCommunityOrEnterprise()
getCommunityOrEnterprise in interface CouchbaseNodeDriverpublic void rebalance()
rebalance in interface CouchbaseNodeDriverpublic void serverAdd(java.lang.String serverToAdd,
java.lang.String username,
java.lang.String password)
serverAdd in interface CouchbaseNodeDriverpublic void serverAddAndRebalance(java.lang.String serverToAdd,
java.lang.String username,
java.lang.String password)
serverAddAndRebalance in interface CouchbaseNodeDriverpublic 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 CouchbaseNodeDriverpublic void addReplicationRule(Entity toCluster, java.lang.String fromBucket, java.lang.String toBucket)
addReplicationRule in interface CouchbaseNodeDriver