Package org.apache.cassandra.transport

Class Server.EventNotifier

java.lang.Object

org.apache.cassandra.schema.SchemaChangeListener

org.apache.cassandra.transport.Server.EventNotifier

All Implemented Interfaces:

IEndpointLifecycleSubscriber

Enclosing class:

Server

public static class Server.EventNotifier
extends SchemaChangeListener
implements IEndpointLifecycleSubscriber

Constructor Summary

Constructors

Constructor	Description
EventNotifier()

Method Summary

Modifier and Type	Method	Description
void	onAlterAggregate(java.lang.String ksName, java.lang.String aggregateName, java.util.List<AbstractType<?>> argTypes)
void	onAlterFunction(java.lang.String ksName, java.lang.String functionName, java.util.List<AbstractType<?>> argTypes)
void	onAlterKeyspace(java.lang.String ksName)
void	onAlterTable(java.lang.String ksName, java.lang.String cfName, boolean affectsStatements)
void	onAlterType(java.lang.String ksName, java.lang.String typeName)
void	onCreateAggregate(java.lang.String ksName, java.lang.String aggregateName, java.util.List<AbstractType<?>> argTypes)
void	onCreateFunction(java.lang.String ksName, java.lang.String functionName, java.util.List<AbstractType<?>> argTypes)
void	onCreateKeyspace(java.lang.String ksName)
void	onCreateTable(java.lang.String ksName, java.lang.String cfName)
void	onCreateType(java.lang.String ksName, java.lang.String typeName)
void	onDown(InetAddressAndPort endpoint)	Called when a node is marked DOWN.
void	onDropAggregate(java.lang.String ksName, java.lang.String aggregateName, java.util.List<AbstractType<?>> argTypes)
void	onDropFunction(java.lang.String ksName, java.lang.String functionName, java.util.List<AbstractType<?>> argTypes)
void	onDropKeyspace(java.lang.String ksName)
void	onDropTable(java.lang.String ksName, java.lang.String cfName)
void	onDropType(java.lang.String ksName, java.lang.String typeName)
void	onJoinCluster(InetAddressAndPort endpoint)	Called when a new node joins the cluster, i.e.
void	onLeaveCluster(InetAddressAndPort endpoint)	Called when a new node leave the cluster (decommission or removeToken).
void	onMove(InetAddressAndPort endpoint)	Called when a node has moved (to a new token).
void	onUp(InetAddressAndPort endpoint)	Called when a node is marked UP.

Methods inherited from class org.apache.cassandra.schema.SchemaChangeListener

onAlterView, onCreateView, onDropView

Methods inherited from class java.lang.Object

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

Constructor Detail

EventNotifier

public EventNotifier()

Method Detail

onJoinCluster

public void onJoinCluster(InetAddressAndPort endpoint)

Description copied from interface: IEndpointLifecycleSubscriber

Called when a new node joins the cluster, i.e. either has just been bootstrapped or "instajoins".

Specified by:

onJoinCluster in interface IEndpointLifecycleSubscriber

Parameters:

endpoint - the newly added endpoint.

onLeaveCluster

public void onLeaveCluster(InetAddressAndPort endpoint)

Description copied from interface: IEndpointLifecycleSubscriber

Called when a new node leave the cluster (decommission or removeToken).

Specified by:

onLeaveCluster in interface IEndpointLifecycleSubscriber

Parameters:

endpoint - the endpoint that is leaving.

onMove

public void onMove(InetAddressAndPort endpoint)

Description copied from interface: IEndpointLifecycleSubscriber

Called when a node has moved (to a new token).

Specified by:

onMove in interface IEndpointLifecycleSubscriber

Parameters:

endpoint - the endpoint that has moved.

onUp

public void onUp(InetAddressAndPort endpoint)

Description copied from interface: IEndpointLifecycleSubscriber

Called when a node is marked UP.

Specified by:

onUp in interface IEndpointLifecycleSubscriber

Parameters:

endpoint - the endpoint marked UP.

onDown

public void onDown(InetAddressAndPort endpoint)

Description copied from interface: IEndpointLifecycleSubscriber

Called when a node is marked DOWN.

Specified by:

onDown in interface IEndpointLifecycleSubscriber

Parameters:

endpoint - the endpoint marked DOWN.

onCreateKeyspace

public void onCreateKeyspace(java.lang.String ksName)

Overrides:

onCreateKeyspace in class SchemaChangeListener

onCreateTable

public void onCreateTable(java.lang.String ksName,
                          java.lang.String cfName)

Overrides:

onCreateTable in class SchemaChangeListener

onCreateType

public void onCreateType(java.lang.String ksName,
                         java.lang.String typeName)

Overrides:

onCreateType in class SchemaChangeListener

onCreateFunction

public void onCreateFunction(java.lang.String ksName,
                             java.lang.String functionName,
                             java.util.List<AbstractType<?>> argTypes)

Overrides:

onCreateFunction in class SchemaChangeListener

onCreateAggregate

public void onCreateAggregate(java.lang.String ksName,
                              java.lang.String aggregateName,
                              java.util.List<AbstractType<?>> argTypes)

Overrides:

onCreateAggregate in class SchemaChangeListener

onAlterKeyspace

public void onAlterKeyspace(java.lang.String ksName)

Overrides:

onAlterKeyspace in class SchemaChangeListener

onAlterTable

public void onAlterTable(java.lang.String ksName,
                         java.lang.String cfName,
                         boolean affectsStatements)

Overrides:

onAlterTable in class SchemaChangeListener

onAlterType

public void onAlterType(java.lang.String ksName,
                        java.lang.String typeName)

Overrides:

onAlterType in class SchemaChangeListener

onAlterFunction

public void onAlterFunction(java.lang.String ksName,
                            java.lang.String functionName,
                            java.util.List<AbstractType<?>> argTypes)

Overrides:

onAlterFunction in class SchemaChangeListener

onAlterAggregate

public void onAlterAggregate(java.lang.String ksName,
                             java.lang.String aggregateName,
                             java.util.List<AbstractType<?>> argTypes)

Overrides:

onAlterAggregate in class SchemaChangeListener

onDropKeyspace

public void onDropKeyspace(java.lang.String ksName)

Overrides:

onDropKeyspace in class SchemaChangeListener

onDropTable

public void onDropTable(java.lang.String ksName,
                        java.lang.String cfName)

Overrides:

onDropTable in class SchemaChangeListener

onDropType

public void onDropType(java.lang.String ksName,
                       java.lang.String typeName)

Overrides:

onDropType in class SchemaChangeListener

onDropFunction

public void onDropFunction(java.lang.String ksName,
                           java.lang.String functionName,
                           java.util.List<AbstractType<?>> argTypes)

Overrides:

onDropFunction in class SchemaChangeListener

onDropAggregate

public void onDropAggregate(java.lang.String ksName,
                            java.lang.String aggregateName,
                            java.util.List<AbstractType<?>> argTypes)

Overrides:

onDropAggregate in class SchemaChangeListener