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
All Methods Instance Methods Concrete Methods 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
-
-
-
-
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 interfaceIEndpointLifecycleSubscriber
- 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 interfaceIEndpointLifecycleSubscriber
- 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 interfaceIEndpointLifecycleSubscriber
- 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 interfaceIEndpointLifecycleSubscriber
- 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 interfaceIEndpointLifecycleSubscriber
- Parameters:
endpoint
- the endpoint marked DOWN.
-
onCreateKeyspace
public void onCreateKeyspace(java.lang.String ksName)
- Overrides:
onCreateKeyspace
in classSchemaChangeListener
-
onCreateTable
public void onCreateTable(java.lang.String ksName, java.lang.String cfName)
- Overrides:
onCreateTable
in classSchemaChangeListener
-
onCreateType
public void onCreateType(java.lang.String ksName, java.lang.String typeName)
- Overrides:
onCreateType
in classSchemaChangeListener
-
onCreateFunction
public void onCreateFunction(java.lang.String ksName, java.lang.String functionName, java.util.List<AbstractType<?>> argTypes)
- Overrides:
onCreateFunction
in classSchemaChangeListener
-
onCreateAggregate
public void onCreateAggregate(java.lang.String ksName, java.lang.String aggregateName, java.util.List<AbstractType<?>> argTypes)
- Overrides:
onCreateAggregate
in classSchemaChangeListener
-
onAlterKeyspace
public void onAlterKeyspace(java.lang.String ksName)
- Overrides:
onAlterKeyspace
in classSchemaChangeListener
-
onAlterTable
public void onAlterTable(java.lang.String ksName, java.lang.String cfName, boolean affectsStatements)
- Overrides:
onAlterTable
in classSchemaChangeListener
-
onAlterType
public void onAlterType(java.lang.String ksName, java.lang.String typeName)
- Overrides:
onAlterType
in classSchemaChangeListener
-
onAlterFunction
public void onAlterFunction(java.lang.String ksName, java.lang.String functionName, java.util.List<AbstractType<?>> argTypes)
- Overrides:
onAlterFunction
in classSchemaChangeListener
-
onAlterAggregate
public void onAlterAggregate(java.lang.String ksName, java.lang.String aggregateName, java.util.List<AbstractType<?>> argTypes)
- Overrides:
onAlterAggregate
in classSchemaChangeListener
-
onDropKeyspace
public void onDropKeyspace(java.lang.String ksName)
- Overrides:
onDropKeyspace
in classSchemaChangeListener
-
onDropTable
public void onDropTable(java.lang.String ksName, java.lang.String cfName)
- Overrides:
onDropTable
in classSchemaChangeListener
-
onDropType
public void onDropType(java.lang.String ksName, java.lang.String typeName)
- Overrides:
onDropType
in classSchemaChangeListener
-
onDropFunction
public void onDropFunction(java.lang.String ksName, java.lang.String functionName, java.util.List<AbstractType<?>> argTypes)
- Overrides:
onDropFunction
in classSchemaChangeListener
-
onDropAggregate
public void onDropAggregate(java.lang.String ksName, java.lang.String aggregateName, java.util.List<AbstractType<?>> argTypes)
- Overrides:
onDropAggregate
in classSchemaChangeListener
-
-