Package org.apache.cassandra.transport

Class Server.EventNotifier

java.lang.Object

org.apache.cassandra.transport.Server.EventNotifier

All Implemented Interfaces:

SchemaChangeListener, IEndpointLifecycleSubscriber

Enclosing class:

Server

public static class Server.EventNotifier
extends Object
implements SchemaChangeListener, IEndpointLifecycleSubscriber

Constructor Summary

Constructors

Constructor	Description
EventNotifier()

Method Summary

Modifier and Type	Method	Description
void	onAlterAggregate(UDAggregate before, UDAggregate after)
void	onAlterFunction(UDFunction before, UDFunction after)
void	onAlterKeyspace(KeyspaceMetadata before, KeyspaceMetadata after)
void	onAlterTable(TableMetadata before, TableMetadata after, boolean affectsStatements)
void	onAlterType(UserType before, UserType after)
void	onCreateAggregate(UDAggregate aggregate)
void	onCreateFunction(UDFunction function)
void	onCreateKeyspace(KeyspaceMetadata keyspace)
void	onCreateTable(TableMetadata table)
void	onCreateType(UserType type)
void	onDown(InetAddressAndPort endpoint)	Called when a node is marked DOWN.
void	onDropAggregate(UDAggregate aggregate)
void	onDropFunction(UDFunction function)
void	onDropKeyspace(KeyspaceMetadata keyspace, boolean dropData)
void	onDropTable(TableMetadata table, boolean dropData)
void	onDropType(UserType type)
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 java.lang.Object

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

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

onAlterView, onCreateView, onDropView, onPreAlterTable, onPreAlterView

Constructor Details

EventNotifier

public EventNotifier()

Method Details

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(KeyspaceMetadata keyspace)

Specified by:

onCreateKeyspace in interface SchemaChangeListener

onCreateTable

public void onCreateTable(TableMetadata table)

Specified by:

onCreateTable in interface SchemaChangeListener

onCreateType

public void onCreateType(UserType type)

Specified by:

onCreateType in interface SchemaChangeListener

onCreateFunction

public void onCreateFunction(UDFunction function)

Specified by:

onCreateFunction in interface SchemaChangeListener

onCreateAggregate

public void onCreateAggregate(UDAggregate aggregate)

Specified by:

onCreateAggregate in interface SchemaChangeListener

onAlterKeyspace

public void onAlterKeyspace(KeyspaceMetadata before,
 KeyspaceMetadata after)

Specified by:

onAlterKeyspace in interface SchemaChangeListener

onAlterTable

public void onAlterTable(TableMetadata before,
 TableMetadata after,
 boolean affectsStatements)

Specified by:

onAlterTable in interface SchemaChangeListener

onAlterType

public void onAlterType(UserType before,
 UserType after)

Specified by:

onAlterType in interface SchemaChangeListener

onAlterFunction

public void onAlterFunction(UDFunction before,
 UDFunction after)

Specified by:

onAlterFunction in interface SchemaChangeListener

onAlterAggregate

public void onAlterAggregate(UDAggregate before,
 UDAggregate after)

Specified by:

onAlterAggregate in interface SchemaChangeListener

onDropKeyspace

public void onDropKeyspace(KeyspaceMetadata keyspace,
 boolean dropData)

Specified by:

onDropKeyspace in interface SchemaChangeListener

onDropTable

public void onDropTable(TableMetadata table,
 boolean dropData)

Specified by:

onDropTable in interface SchemaChangeListener

onDropType

public void onDropType(UserType type)

Specified by:

onDropType in interface SchemaChangeListener

onDropFunction

public void onDropFunction(UDFunction function)

Specified by:

onDropFunction in interface SchemaChangeListener

onDropAggregate

public void onDropAggregate(UDAggregate aggregate)

Specified by:

onDropAggregate in interface SchemaChangeListener