org.rhq.plugins.cassandra

Class KeyspaceComponent

java.lang.Object

org.rhq.plugins.cassandra.KeyspaceComponent

All Implemented Interfaces:

AvailabilityFacet, ConfigurationFacet, ResourceComponent<ResourceComponent<?>>, OperationFacet, JMXComponent<ResourceComponent<?>>

public class KeyspaceComponent
extends Object
implements ResourceComponent<ResourceComponent<?>>, ConfigurationFacet, JMXComponent<ResourceComponent<?>>, OperationFacet

Author:

John Sanda

Field Summary

Fields inherited from interface org.rhq.plugins.jmx.JMXComponent

CREDENTIALS_CONFIG_PROP, PRINCIPAL_CONFIG_PROP

Constructor Summary

Constructors

Constructor and Description
KeyspaceComponent()

Method Summary

Methods

Modifier and Type	Method and Description
OperationResult	cleanup()
boolean	clearCommitLog()
OperationResult	compactKeyspace(String... columnFamilies)
org.rhq.core.domain.measurement.AvailabilityType	getAvailability()
CassandraNodeComponent	getCassandraNodeComponent()
org.rhq.core.domain.configuration.PropertySimple	getCommitLogProperty()
org.mc4j.ems.connection.EmsConnection	getEmsConnection()
org.rhq.core.domain.configuration.PropertyList	getKeySpaceDataFileLocations()
String	getKeyspaceName()
OperationResult	invokeOperation(String name, org.rhq.core.domain.configuration.Configuration parameters)
protected org.mc4j.ems.connection.bean.EmsBean	loadBean(String objectName) Loads the bean with the given object name.
org.rhq.core.domain.configuration.Configuration	loadResourceConfiguration()
OperationResult	repairKeyspace(String... columnFamilies)
OperationResult	repairPrimaryRange()
void	start(ResourceContext<ResourceComponent<?>> context)
void	stop()
OperationResult	takeSnapshot(org.rhq.core.domain.configuration.Configuration parameters, String... columnFamilies)
void	updateResourceConfiguration(ConfigurationUpdateReport report)

Methods inherited from class java.lang.Object

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

Constructor Detail

KeyspaceComponent

public KeyspaceComponent()

Method Detail

start

public void start(ResourceContext<ResourceComponent<?>> context)
           throws Exception

Specified by:

start in interface ResourceComponent<ResourceComponent<?>>

Throws:

Exception

stop

public void stop()

Specified by:

stop in interface ResourceComponent<ResourceComponent<?>>

getAvailability

public org.rhq.core.domain.measurement.AvailabilityType getAvailability()

Specified by:

getAvailability in interface AvailabilityFacet

getEmsConnection

public org.mc4j.ems.connection.EmsConnection getEmsConnection()

Specified by:

getEmsConnection in interface JMXComponent<ResourceComponent<?>>

loadResourceConfiguration

public org.rhq.core.domain.configuration.Configuration loadResourceConfiguration()
                                                                          throws Exception

Specified by:

loadResourceConfiguration in interface ConfigurationFacet

Throws:

Exception

updateResourceConfiguration

public void updateResourceConfiguration(ConfigurationUpdateReport report)

Specified by:

updateResourceConfiguration in interface ConfigurationFacet

invokeOperation

public OperationResult invokeOperation(String name,
                              org.rhq.core.domain.configuration.Configuration parameters)
                                throws Exception

Specified by:

invokeOperation in interface OperationFacet

Throws:

Exception

repairKeyspace

public OperationResult repairKeyspace(String... columnFamilies)

repairPrimaryRange

public OperationResult repairPrimaryRange()

cleanup

public OperationResult cleanup()

compactKeyspace

public OperationResult compactKeyspace(String... columnFamilies)

takeSnapshot

public OperationResult takeSnapshot(org.rhq.core.domain.configuration.Configuration parameters,
                           String... columnFamilies)

getKeySpaceDataFileLocations

public org.rhq.core.domain.configuration.PropertyList getKeySpaceDataFileLocations()

getCommitLogProperty

public org.rhq.core.domain.configuration.PropertySimple getCommitLogProperty()

clearCommitLog

public boolean clearCommitLog()

getCassandraNodeComponent

public CassandraNodeComponent getCassandraNodeComponent()

loadBean

protected org.mc4j.ems.connection.bean.EmsBean loadBean(String objectName)

Loads the bean with the given object name. Subclasses are free to override this method in order to load the bean.

Parameters:

objectName - the name of the bean to load

Returns:

the bean that is loaded

getKeyspaceName

public String getKeyspaceName()

Returns:

keyspace name