Field Detail

• CLUSTER_NAME

  static final BasicAttributeSensorAndConfigKey<java.lang.String> CLUSTER_NAME

• ENDPOINT_SNITCH_NAME

  static final ConfigKey<java.lang.String> ENDPOINT_SNITCH_NAME

• SEED_SUPPLIER

  static final ConfigKey<com.google.common.base.Supplier<java.util.Set<Entity>>> SEED_SUPPLIER

• TOKEN_GENERATOR_CLASS

  static final ConfigKey<java.lang.Class<? extends TokenGenerator>> TOKEN_GENERATOR_CLASS

• TOKEN_SHIFT

  static final ConfigKey<java.math.BigInteger> TOKEN_SHIFT

• USE_VNODES

  static final ConfigKey<java.lang.Boolean> USE_VNODES

• NUM_TOKENS_PER_NODE

  static final ConfigKey<java.lang.Integer> NUM_TOKENS_PER_NODE

  num_tokens will automatically be reset to 1 for each node if USE_VNODES is false.

• DELAY_BEFORE_ADVERTISING_CLUSTER

  static final ConfigKey<Duration> DELAY_BEFORE_ADVERTISING_CLUSTER

  Additional time after the nodes in the cluster are up when starting before announcing the cluster as up.

  Useful to ensure nodes have synchronized.

  On 1.2.2 this could be as much as 120s when using 2 seed nodes, or just a few seconds with 1 seed node. On 1.2.9 it seems a few seconds is sufficient even with 2 seed nodes

• DATACENTER_USAGE

  static final AttributeSensor<com.google.common.collect.Multimap<java.lang.String,Entity>> DATACENTER_USAGE

• DATACENTERS

  static final AttributeSensor<java.util.Set<java.lang.String>> DATACENTERS

• HAS_PUBLISHED_SEEDS

  static final AttributeSensor<java.lang.Boolean> HAS_PUBLISHED_SEEDS

• CURRENT_SEEDS

  static final AttributeSensor<java.util.Set<Entity>> CURRENT_SEEDS

• HOSTNAME

  static final AttributeSensor<java.lang.String> HOSTNAME

• CASSANDRA_CLUSTER_NODES

  static final AttributeSensor<java.util.List<java.lang.String>> CASSANDRA_CLUSTER_NODES

• THRIFT_PORT

  static final AttributeSensor<java.lang.Integer> THRIFT_PORT

• FIRST_NODE_STARTED_TIME_UTC

  static final AttributeSensor<java.lang.Long> FIRST_NODE_STARTED_TIME_UTC

• QUEUED_START_NODES

  static final AttributeSensor<java.util.List<Entity>> QUEUED_START_NODES

• SCHEMA_VERSION_COUNT

  static final AttributeSensor<java.lang.Integer> SCHEMA_VERSION_COUNT

• READ_PENDING

  static final AttributeSensor<java.lang.Long> READ_PENDING

• READ_ACTIVE

  static final AttributeSensor<java.lang.Integer> READ_ACTIVE

• WRITE_PENDING

  static final AttributeSensor<java.lang.Long> WRITE_PENDING

• WRITE_ACTIVE

  static final AttributeSensor<java.lang.Integer> WRITE_ACTIVE

• THRIFT_PORT_LATENCY_PER_NODE

  static final AttributeSensor<java.lang.Long> THRIFT_PORT_LATENCY_PER_NODE

• READS_PER_SECOND_LAST_PER_NODE

  static final AttributeSensor<java.lang.Double> READS_PER_SECOND_LAST_PER_NODE

• WRITES_PER_SECOND_LAST_PER_NODE

  static final AttributeSensor<java.lang.Double> WRITES_PER_SECOND_LAST_PER_NODE

• PROCESS_CPU_TIME_FRACTION_LAST_PER_NODE

  static final AttributeSensor<java.lang.Double> PROCESS_CPU_TIME_FRACTION_LAST_PER_NODE

• READS_PER_SECOND_IN_WINDOW_PER_NODE

  static final AttributeSensor<java.lang.Double> READS_PER_SECOND_IN_WINDOW_PER_NODE

• WRITES_PER_SECOND_IN_WINDOW_PER_NODE

  static final AttributeSensor<java.lang.Double> WRITES_PER_SECOND_IN_WINDOW_PER_NODE

• THRIFT_PORT_LATENCY_IN_WINDOW_PER_NODE

  static final AttributeSensor<java.lang.Double> THRIFT_PORT_LATENCY_IN_WINDOW_PER_NODE

• PROCESS_CPU_TIME_FRACTION_IN_WINDOW_PER_NODE

  static final AttributeSensor<java.lang.Double> PROCESS_CPU_TIME_FRACTION_IN_WINDOW_PER_NODE

• UPDATE

  static final MethodEffector<java.lang.Void> UPDATE

• EXECUTE_SCRIPT

  static final Effector<java.lang.String> EXECUTE_SCRIPT

• DEFAULT_SEED_QUORUM

  static final int DEFAULT_SEED_QUORUM

  Sets the number of nodes used to seed the cluster.

  Version 1.2.2 is buggy and requires a big delay for 2 nodes both seeds to reconcile, with 1.2.9 this seems fine, with just a few seconds' delay after starting.

  See Also:

  , Constant Field Values

• DELAY_AFTER_FIRST

  static final Duration DELAY_AFTER_FIRST

  Can insert a delay after the first node comes up.

  Reportedly not needed with 1.2.9, but we are still seeing some seed failures so re-introducing it. (This does not seem to help with the bug in 1.2.2.)

• DELAY_BETWEEN_STARTS

  static final Duration DELAY_BETWEEN_STARTS

  If set (ie non-null), this waits the indicated time after a successful launch of one node before starting the next. (If it is null, all nodes start simultaneously, possibly after the DELAY_AFTER_FIRST.)

  When subsequent nodes start simultaneously, we occasionally see schema disagreement problems; if nodes start sequentially, we occasionally get "no sources for (tokenRange]" problems. Either way the node stops. Ideally this can be solved at the Cassandra level, but if not, we will have to introduce some restarts at the Cassandra nodes (which does seem to resolve the problems.)

• WAIT_FOR_FIRST

  static final boolean WAIT_FOR_FIRST

  Whether to wait for the first node to start up

  not sure whether this is needed or not. Need to test in env where not all nodes are seed nodes, what happens if non-seed nodes start before the seed nodes?

  See Also:

  Constant Field Values

Method Detail

• update

  void update()

• getClusterName

  java.lang.String getClusterName()

  The name of the cluster.

• gatherPotentialSeeds

  java.util.Set<Entity> gatherPotentialSeeds()

• gatherPotentialRunningSeeds

  java.util.Set<Entity> gatherPotentialRunningSeeds()

• executeScript

  java.lang.String executeScript(java.lang.String commands)