brooklyn.entity.nosql.cassandra
[Java] Class CassandraClusterImpl.SeedTracker

java.lang.Object
  brooklyn.entity.nosql.cassandra.CassandraClusterImpl.SeedTracker

protected class CassandraClusterImpl.SeedTracker

For tracking our seeds. This gets fiddly! High-level logic is:

• If we have never reached quorum (i.e. have never published seeds), then continue to wait for quorum; because entity-startup may be blocking for this. This is handled by the seedSupplier.
• If we previously reached quorum (i.e. have previousy published seeds), then always update; we never want stale/dead entities listed in our seeds.
• If an existing seed looks unhealthy, then replace it.
• If a new potential seed becomes available (and we're in need of more), then add it.
  Also note that CassandraFabric can take over, because it know about multiple sub-clusters! It will provide a different CassandraCluster#SEED_SUPPLIER#SEED_SUPPLIER. Each time we think that our seeds need to change, we call that. The fabric will call into CassandraClusterImpl#gatherPotentialSeeds()#gatherPotentialSeeds() to find out what's available.

  Authors:

  aled

  ---

  Method Summary
  java.util.Set	gatherPotentialRunningSeeds()
  java.util.Set	gatherPotentialSeeds()
  protected java.util.Set	getSeeds()
  boolean	isRunningSeed(Entity member)
  boolean	isViableSeed(Entity member)
  void	onHostnameChanged(Entity member, java.lang.String hostname)
  void	onMemberRemoved(Entity member)
  void	onServiceUpChanged(Entity member, java.lang.Boolean serviceUp)
  void	refreshSeeds()

   

  Methods inherited from class java.lang.Object
  java.lang.Object#wait(), java.lang.Object#wait(long), java.lang.Object#wait(long, int), java.lang.Object#equals(java.lang.Object), java.lang.Object#toString(), java.lang.Object#hashCode(), java.lang.Object#getClass(), java.lang.Object#notify(), java.lang.Object#notifyAll()

   

  Method Detail

  gatherPotentialRunningSeeds

  public java.util.Set gatherPotentialRunningSeeds()

  ---

  gatherPotentialSeeds

  public java.util.Set gatherPotentialSeeds()

  ---

  getSeeds

  protected java.util.Set getSeeds()

  ---

  isRunningSeed

  public boolean isRunningSeed(Entity member)

  ---

  isViableSeed

  public boolean isViableSeed(Entity member)

  ---

  onHostnameChanged

  public void onHostnameChanged(Entity member, java.lang.String hostname)

  ---

  onMemberRemoved

  public void onMemberRemoved(Entity member)

  ---

  onServiceUpChanged

  public void onServiceUpChanged(Entity member, java.lang.Boolean serviceUp)

  ---

  refreshSeeds

  public void refreshSeeds()

  ---

   

  Brooklyn Multi-Cloud Application Management Platform
  brooklyncentral.github.com. Apache License. © 2012.

  ---