'https://github.com/brooklyncentral/brooklyn-cassandra'
which is a pure YAML template
for a database cluster.@Deprecated public class CassandraDatacenterImpl extends DynamicClusterImpl implements CassandraDatacenter
Modifier and Type | Class and Description |
---|---|
static class |
CassandraDatacenterImpl.MemberTrackingPolicy
Deprecated.
|
DynamicClusterImpl.DefaultRemovalStrategy
AbstractEntity.BasicConfigurationSupport, AbstractEntity.BasicEnricherSupport, AbstractEntity.BasicGroupSupport, AbstractEntity.BasicPolicySupport, AbstractEntity.BasicSensorSupport, AbstractEntity.BasicSubscriptionSupport
DynamicCluster.NodePlacementStrategy, DynamicCluster.ZoneFailureDetector
Entity.AdjunctSupport<T extends EntityAdjunct>, Entity.EnricherSupport, Entity.GroupSupport, Entity.PolicySupport, Entity.SensorSupport
BrooklynObject.RelationSupport<T extends BrooklynObject>, BrooklynObject.SubscriptionSupport, BrooklynObject.TagSupport
Configurable.ConfigurationSupport
Startable.RestartEffectorBody, Startable.StartEffectorBody, Startable.StopEffectorBody
Resizable.InsufficientCapacityException
EntityInternal.EnricherSupportInternal, EntityInternal.EntitySubscriptionSupportInternal, EntityInternal.FeedSupport, EntityInternal.GroupSupportInternal, EntityInternal.PolicySupportInternal, EntityInternal.SensorSupportInternal
BrooklynObjectInternal.ConfigurationSupportInternal, BrooklynObjectInternal.RelationSupportInternal<T extends BrooklynObject>, BrooklynObjectInternal.SubscriptionSupportInternal
APPLICATION_ID, CATALOG_ID, CHILD_ADDED, CHILD_REMOVED, CONFIG_KEY_ADDED, CONFIG_KEY_REMOVED, DEFAULT_DISPLAY_NAME, EFFECTOR_ADDED, EFFECTOR_CHANGED, EFFECTOR_REMOVED, ENTITY_ID, GROUP_ADDED, GROUP_REMOVED, LOCATION_ADDED, LOCATION_REMOVED, POLICY_ADDED, POLICY_REMOVED, SENSOR_ADDED, SENSOR_REMOVED
CASSANDRA_CLUSTER_NODES, CLUSTER_NAME, CURRENT_SEEDS, DATACENTER_USAGE, DATACENTERS, DEFAULT_SEED_QUORUM, DELAY_AFTER_FIRST, DELAY_BEFORE_ADVERTISING_CLUSTER, DELAY_BETWEEN_STARTS, ENDPOINT_SNITCH_NAME, EXECUTE_SCRIPT, FIRST_NODE_STARTED_TIME_UTC, HAS_PUBLISHED_SEEDS, HOSTNAME, NUM_TOKENS_PER_NODE, PROCESS_CPU_TIME_FRACTION_IN_WINDOW_PER_NODE, PROCESS_CPU_TIME_FRACTION_LAST_PER_NODE, QUEUED_START_NODES, READ_ACTIVE, READ_PENDING, READS_PER_SECOND_IN_WINDOW_PER_NODE, READS_PER_SECOND_LAST_PER_NODE, SCHEMA_VERSION_COUNT, SEED_SUPPLIER, THRIFT_PORT, THRIFT_PORT_LATENCY_IN_WINDOW_PER_NODE, THRIFT_PORT_LATENCY_PER_NODE, TOKEN_GENERATOR_CLASS, TOKEN_SHIFT, UPDATE, USE_VNODES, WAIT_FOR_FIRST, WRITE_ACTIVE, WRITE_PENDING, WRITES_PER_SECOND_IN_WINDOW_PER_NODE, WRITES_PER_SECOND_LAST_PER_NODE
AVAILABILITY_ZONE_NAMES, CLUSTER, CLUSTER_MEMBER, CLUSTER_MEMBER_ID, CLUSTER_ONE_AND_ALL_MEMBERS_UP, CUSTOM_CHILD_FLAGS, ENABLE_AVAILABILITY_ZONES, ENTITY_QUARANTINED, FAILED_SUB_LOCATIONS, FIRST_MEMBER_SPEC, INITIAL_QUORUM_SIZE, MAX_CONCURRENT_CHILD_COMMANDS, MAX_SIZE, MEMBER_SPEC, NUM_AVAILABILITY_ZONES, QUARANTINE_FAILED_ENTITIES, QUARANTINE_FILTER, QUARANTINE_GROUP, REMOVAL_STRATEGY, RESIZE_BY_DELTA, RESTART_MODE, SERVICE_STATE_ACTUAL, START_TIMEOUT, SUB_LOCATIONS, ZONE_FAILURE_DETECTOR, ZONE_PLACEMENT_STRATEGY
FIRST, GROUP_MEMBERS, MEMBER_DELEGATE_CHILDREN, MEMBER_DELEGATE_NAME_FORMAT, RUNNING_QUORUM_CHECK, UP_QUORUM_CHECK
GROUP_SIZE, MEMBER_ADDED, MEMBER_REMOVED
INITIAL_SIZE
RESTART, SERVICE_UP, START, STOP
REPLACE_MEMBER
DATASTORE_URL
Constructor and Description |
---|
CassandraDatacenterImpl()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
java.lang.String |
executeScript(java.lang.String commands)
Deprecated.
|
java.util.Set<Entity> |
gatherPotentialRunningSeeds()
Deprecated.
|
java.util.Set<Entity> |
gatherPotentialSeeds()
Deprecated.
|
java.lang.String |
getClusterName()
Deprecated.
The name of the cluster.
|
java.util.Collection<Entity> |
grow(int delta)
Deprecated.
Note for sub-classes; this method can be called while synchronized on
DynamicClusterImpl.mutex . |
void |
init()
Deprecated.
Default entity initialization sets ID sensors and calls
AbstractEntity.initEnrichers() . |
void |
start(java.util.Collection<? extends Location> locations)
Deprecated.
Start the entity in the given collection of locations.
|
void |
stop()
Deprecated.
Stop the entity.
|
void |
update()
Deprecated.
|
addNode, rebind, removeChild, replaceMember, resize, resizeByDelta, restart, setMemberSpec, setRemovalStrategy, setZoneFailureDetector, setZonePlacementStrategy
addMember, addMemberChild, addMemberChild, addMemberInternal, getCurrentSize, getMembers, hasMember, removeMember, setManagementContext, setMembers, setMembers
addChild, addChild, addFeed, addLocations, addLocationsWithoutPublishing, clearLocations, clearParent, config, configure, configure, destroy, enrichers, equals, feeds, firstLocation, getApplication, getApplicationId, getAttribute, getChildren, getConfig, getConfig, getCreationTime, getDisplayName, getEffector, getEntityType, getExecutionContext, getIconUrl, getLocations, getManagementContext, getManagementSupport, getMutableEntityType, getParent, getProxy, getProxyIfAvailable, getRebindSupport, groups, hashCode, invalidateReferences, invoke, invoke, invoke, onManagementBecomingMaster, onManagementNoLongerMaster, onManagementStarted, onManagementStarting, onManagementStopped, policies, relations, removeLocations, requestPersist, resetProxy, sensors, setConfigEvenIfOwned, setConfigEvenIfOwned, setDisplayName, setParent, setProxy, subscriptions, toMetadataRecord, toString
addSearchPath, getCatalogItemId, getCatalogItemIdSearchPath, getId, setCatalogItemId, setCatalogItemIdAndSearchPath, stackCatalogItemId, tags
addNode, resizeByDelta, setMemberSpec, setRemovalStrategy, setZoneFailureDetector, setZonePlacementStrategy
getFirst, setMembers, setMembers
addChild, addChild, addMember, addMemberChild, addMemberChild, getCurrentSize, getMembers, hasMember, removeMember
addFeed, clearParent, enrichers, getApplication, getApplicationId, getAttribute, getChildren, getConfig, getCreationTime, getDisplayName, getEntityType, getIconUrl, getId, getLocations, getParent, groups, invoke, policies, relations, removeChild, sensors, setDisplayName, setParent
getCatalogItemId, getCatalogItemIdSearchPath, subscriptions, tags
config, getConfig
getCurrentSize, resize
replaceMember
addSearchPath, setCatalogItemId, setCatalogItemIdAndSearchPath, stackCatalogItemId
public void init()
AbstractEntity
AbstractEntity.initEnrichers()
.init
in class DynamicClusterImpl
public java.util.Set<Entity> gatherPotentialSeeds()
gatherPotentialSeeds
in interface CassandraDatacenter
public java.util.Set<Entity> gatherPotentialRunningSeeds()
gatherPotentialRunningSeeds
in interface CassandraDatacenter
public java.lang.String getClusterName()
CassandraDatacenter
getClusterName
in interface CassandraDatacenter
public java.util.Collection<Entity> grow(int delta)
DynamicClusterImpl
DynamicClusterImpl.mutex
.public void start(java.util.Collection<? extends Location> locations)
Startable
Some entities may define custom Effector
implementations which support
a richer set of parameters. See the entity-specific Startable.START
effector declaration.
start
in interface Startable
start
in class DynamicClusterImpl
public void stop()
Startable
Some entities may define custom Effector
implementations which support
a richer set of parameters. See the entity-specific Startable.STOP
effector declaration.
stop
in interface Startable
stop
in class DynamicClusterImpl
public void update()
update
in interface CassandraDatacenter
public java.lang.String executeScript(java.lang.String commands)
executeScript
in interface CassandraDatacenter