Package | Description |
---|---|
org.apache.cassandra.audit | |
org.apache.cassandra.diag | |
org.apache.cassandra.diag.store | |
org.apache.cassandra.gms | |
org.apache.cassandra.locator | |
org.apache.cassandra.schema |
Modifier and Type | Class and Description |
---|---|
class |
AuditEvent
wrapper to expose audit events as
DiagnosticEvent s. |
Modifier and Type | Method and Description |
---|---|
<E extends DiagnosticEvent> |
DiagnosticEventService.hasSubscribers(java.lang.Class<E> event)
Indicates if any
Consumer has been registered for the specified class of events. |
<E extends DiagnosticEvent,T extends java.lang.Enum<T>> |
DiagnosticEventService.hasSubscribers(java.lang.Class<E> event,
T eventType)
Indicates if any
Consumer has been registered for the specified class of events. |
<E extends DiagnosticEvent> |
DiagnosticEventService.isEnabled(java.lang.Class<E> event)
Indicates if events are enabled for specified event class based on
DatabaseDescriptor.diagnosticEventsEnabled()
and DiagnosticEventService.hasSubscribers(Class) . |
<E extends DiagnosticEvent,T extends java.lang.Enum<T>> |
DiagnosticEventService.isEnabled(java.lang.Class<E> event,
T eventType)
Indicates if events are enabled for specified event class based on
DatabaseDescriptor.diagnosticEventsEnabled()
and DiagnosticEventService.hasSubscribers(Class, Enum) . |
<E extends DiagnosticEvent> |
DiagnosticEventService.subscribe(java.lang.Class<E> event,
java.util.function.Consumer<E> consumer)
Registers event handler for specified class of events.
|
<E extends DiagnosticEvent,T extends java.lang.Enum<T>> |
DiagnosticEventService.subscribe(java.lang.Class<E> event,
T eventType,
java.util.function.Consumer<E> consumer)
Registers event handler for specified class of events.
|
<E extends DiagnosticEvent> |
DiagnosticEventService.unsubscribe(java.lang.Class<E> event,
java.util.function.Consumer<E> consumer)
De-registers event handler from receiving any further events.
|
<E extends DiagnosticEvent> |
DiagnosticEventService.unsubscribe(java.util.function.Consumer<E> consumer)
De-registers event handler from receiving any further events.
|
Modifier and Type | Method and Description |
---|---|
void |
DiagnosticEventService.publish(DiagnosticEvent event)
Makes provided event available to all subscribers.
|
Modifier and Type | Method and Description |
---|---|
void |
DiagnosticEventService.subscribeAll(java.util.function.Consumer<DiagnosticEvent> consumer)
Registers event handler for all DiagnosticEvents published from this point.
|
Modifier and Type | Method and Description |
---|---|
java.util.NavigableMap<java.lang.Long,DiagnosticEvent> |
DiagnosticEventMemoryStore.scan(java.lang.Long id,
int limit) |
java.util.NavigableMap<T,DiagnosticEvent> |
DiagnosticEventStore.scan(T key,
int limit)
Returns a view on all events with a key greater than the provided value (inclusive) up to the specified
number of results.
|
Modifier and Type | Method and Description |
---|---|
void |
DiagnosticEventMemoryStore.store(DiagnosticEvent event) |
void |
DiagnosticEventStore.store(DiagnosticEvent event)
Stores provided event and returns the new associated store key for it.
|
Modifier and Type | Class and Description |
---|---|
class |
GossiperEvent
DiagnosticEvent implementation for
Gossiper activities. |
Modifier and Type | Class and Description |
---|---|
class |
TokenMetadataEvent
Events related to
TokenMetadata changes. |
Modifier and Type | Class and Description |
---|---|
class |
SchemaEvent |
Copyright © 2009-2022 The Apache Software Foundation