org.apache.brooklyn.entity.nosql.couchbase

Class CouchbaseNodeSshDriver

java.lang.Object

org.apache.brooklyn.entity.software.base.AbstractSoftwareProcessDriver

org.apache.brooklyn.entity.software.base.AbstractSoftwareProcessSshDriver

org.apache.brooklyn.entity.nosql.couchbase.CouchbaseNodeSshDriver

All Implemented Interfaces:

EntityDriver, CouchbaseNodeDriver, NaiveScriptRunner, SoftwareProcessDriver

public class CouchbaseNodeSshDriver
extends AbstractSoftwareProcessSshDriver
implements CouchbaseNodeDriver

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	CouchbaseNodeSshDriver.DownloadLinkSegmentComputer

Field Summary

Fields inherited from class org.apache.brooklyn.entity.software.base.AbstractSoftwareProcessSshDriver

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 Summary

Constructors

Constructor and Description
CouchbaseNodeSshDriver(CouchbaseNodeImpl entity, SshMachineLocation machine)

Method Summary

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() Implementations should fail if the return code is non-zero, by throwing some appropriate exception.
java.lang.String	getCommunityOrEnterprise()
java.lang.String	getDownloadLinkOsTagWithPrefix()
java.lang.String	getDownloadLinkPreVersionSeparator()
java.lang.String	getOsTag()
java.lang.String	getVersion()
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	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)

Methods inherited from class org.apache.brooklyn.entity.software.base.AbstractSoftwareProcessSshDriver

checkNoHostnameBug, copyCustomizeResources, copyInstallResources, copyPreInstallResources, copyResource, copyResource, execute, execute, execute, getAddress, getHostname, getLocation, getMachine, getPortsUsed, getSubnetAddress, getSubnetHostname, prepare, runPostCustomizeCommand, runPostInstallCommand, runPostLaunchCommand, runPreCustomizeCommand, runPreInstallCommand, runPreLaunchCommand, setup

Methods inherited from class org.apache.brooklyn.entity.software.base.AbstractSoftwareProcessDriver

copyResource, copyResource, copyResource, copyResource, copyResource, copyResource, copyResource, copyRuntimeResources, copyTemplate, copyTemplate, copyTemplate, getArchiveNameFormat, getEntity, getExpandedInstallDir, getInstallDir, getResource, getResourceAsString, getRunDir, getShellEnvironment, kill, postLaunch, preInstall, processTemplate, processTemplate, processTemplate, processTemplate, processTemplateContents, processTemplateContents, rebind, restart, setExpandedInstallDir, start

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.brooklyn.entity.software.base.SoftwareProcessDriver

getEntity, kill, rebind, restart, start

Methods inherited from interface org.apache.brooklyn.api.entity.drivers.EntityDriver

getLocation

Constructor Detail

CouchbaseNodeSshDriver

public CouchbaseNodeSshDriver(CouchbaseNodeImpl entity,
                              SshMachineLocation machine)

Method Detail

couchbaseCli

public static java.lang.String couchbaseCli(java.lang.String cmd)

install

public void install()

Description copied from class: AbstractSoftwareProcessDriver

Implementations should fail if the return code is non-zero, by throwing some appropriate exception.

Specified by:

install in class AbstractSoftwareProcessDriver

customize

public void customize()

Description copied from class: AbstractSoftwareProcessDriver

Implementations should fail if the return code is non-zero, by throwing some appropriate exception.

Specified by:

customize in class AbstractSoftwareProcessDriver

launch

public void launch()

Description copied from class: AbstractSoftwareProcessDriver

Implementations should fail if the return code is non-zero, by throwing some appropriate exception.

Specified by:

launch in class AbstractSoftwareProcessDriver

isRunning

public boolean isRunning()

Description copied from interface: SoftwareProcessDriver

Whether the entity components have started.

Specified by:

isRunning in interface SoftwareProcessDriver

stop

public void stop()

Description copied from interface: SoftwareProcessDriver

Performs software stop (or queues tasks to do this)

Specified by:

stop in interface SoftwareProcessDriver

Specified by:

stop in class AbstractSoftwareProcessDriver

See Also:

Startable.stop()

getVersion

public java.lang.String getVersion()

Overrides:

getVersion in class AbstractSoftwareProcessDriver

getOsTag

public java.lang.String getOsTag()

Specified by:

getOsTag in interface CouchbaseNodeDriver

getDownloadLinkOsTagWithPrefix

public java.lang.String getDownloadLinkOsTagWithPrefix()

Specified by:

getDownloadLinkOsTagWithPrefix in interface CouchbaseNodeDriver

getDownloadLinkPreVersionSeparator

public java.lang.String getDownloadLinkPreVersionSeparator()

Specified by:

getDownloadLinkPreVersionSeparator in interface CouchbaseNodeDriver

getCommunityOrEnterprise

public java.lang.String getCommunityOrEnterprise()

Specified by:

getCommunityOrEnterprise in interface CouchbaseNodeDriver

rebalance

public void rebalance()

Specified by:

rebalance in interface CouchbaseNodeDriver

serverAdd

public void serverAdd(java.lang.String serverToAdd,
                      java.lang.String username,
                      java.lang.String password)

Specified by:

serverAdd in interface CouchbaseNodeDriver

serverAddAndRebalance

public void serverAddAndRebalance(java.lang.String serverToAdd,
                                  java.lang.String username,
                                  java.lang.String password)

Specified by:

serverAddAndRebalance in interface CouchbaseNodeDriver

bucketCreate

public void bucketCreate(java.lang.String bucketName,
                         java.lang.String bucketType,
                         java.lang.Integer bucketPort,
                         java.lang.Integer bucketRamSize,
                         java.lang.Integer bucketReplica)

Specified by:

bucketCreate in interface CouchbaseNodeDriver

addReplicationRule

public void addReplicationRule(Entity toCluster,
                               java.lang.String fromBucket,
                               java.lang.String toBucket)

Specified by:

addReplicationRule in interface CouchbaseNodeDriver