org.apache.brooklyn.entity.nosql.cassandra.customsnitch

Class MultiCloudSnitch

java.lang.Object

AbstractNetworkTopologySnitch

org.apache.brooklyn.entity.nosql.cassandra.customsnitch.MultiCloudSnitch

public class MultiCloudSnitch
extends AbstractNetworkTopologySnitch

A snitch that can be configured to work across clouds. It uses and extends the cassandra-rackdc.properties (which is used by the GossipingPropertyFileSnitch) to add a publicip and privateip configuration.

The code is very similar to Ec2MultiRegionSnitch, except that it uses the the config file rather than querying EC2 to get the IPs.

If two nodes are in the same datacenter, they will attempt to communicate using the privateip. If they are in different datacenters, they will use the publicip.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	SNITCH_PROPERTIES_FILENAME

Constructor Summary

Constructors

Constructor and Description
MultiCloudSnitch()

Method Summary

Modifier and Type	Method and Description
java.lang.String	getDatacenter(java.net.InetAddress endpoint)
java.lang.String	getRack(java.net.InetAddress endpoint)
void	gossiperStarting()
void	onAlive(java.net.InetAddress endpoint, EndpointState state)
void	onChange(java.net.InetAddress endpoint, ApplicationState state, VersionedValue value)
void	onDead(java.net.InetAddress endpoint, EndpointState state)
void	onJoin(java.net.InetAddress endpoint, EndpointState epState)
void	onRemove(java.net.InetAddress endpoint)
void	onRestart(java.net.InetAddress endpoint, EndpointState state)
void	reloadConfiguration()

Methods inherited from class java.lang.Object

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

Field Detail

SNITCH_PROPERTIES_FILENAME

public static final java.lang.String SNITCH_PROPERTIES_FILENAME

See Also:

Constant Field Values

Constructor Detail

MultiCloudSnitch

public MultiCloudSnitch()
                 throws ConfigurationException

Throws:

ConfigurationException

Method Detail

reloadConfiguration

public void reloadConfiguration()
                         throws ConfigurationException

Throws:

ConfigurationException

getRack

public java.lang.String getRack(java.net.InetAddress endpoint)

getDatacenter

public java.lang.String getDatacenter(java.net.InetAddress endpoint)

onJoin

public void onJoin(java.net.InetAddress endpoint,
                   EndpointState epState)

onChange

public void onChange(java.net.InetAddress endpoint,
                     ApplicationState state,
                     VersionedValue value)

onAlive

public void onAlive(java.net.InetAddress endpoint,
                    EndpointState state)

onDead

public void onDead(java.net.InetAddress endpoint,
                   EndpointState state)

onRestart

public void onRestart(java.net.InetAddress endpoint,
                      EndpointState state)

onRemove

public void onRemove(java.net.InetAddress endpoint)

gossiperStarting

public void gossiperStarting()