Package | Description |
---|---|
org.apache.cassandra.gms | |
org.apache.cassandra.locator | |
org.apache.cassandra.repair | |
org.apache.cassandra.service | |
org.apache.cassandra.streaming |
Modifier and Type | Method and Description |
---|---|
static ApplicationState |
ApplicationState.valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.
|
static ApplicationState[] |
ApplicationState.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
java.util.Set<java.util.Map.Entry<ApplicationState,VersionedValue>> |
EndpointState.states() |
Modifier and Type | Method and Description |
---|---|
void |
EndpointState.addApplicationState(ApplicationState key,
VersionedValue value) |
void |
Gossiper.addLocalApplicationState(ApplicationState applicationState,
VersionedValue value) |
void |
IEndpointStateChangeSubscriber.beforeChange(java.net.InetAddress endpoint,
EndpointState currentState,
ApplicationState newStateKey,
VersionedValue newValue) |
VersionedValue |
EndpointState.getApplicationState(ApplicationState key) |
void |
Gossiper.injectApplicationState(java.net.InetAddress endpoint,
ApplicationState state,
VersionedValue value) |
void |
IEndpointStateChangeSubscriber.onChange(java.net.InetAddress endpoint,
ApplicationState state,
VersionedValue value) |
Modifier and Type | Method and Description |
---|---|
void |
EndpointState.addApplicationStates(java.util.Map<ApplicationState,VersionedValue> values) |
void |
EndpointState.addApplicationStates(java.util.Set<java.util.Map.Entry<ApplicationState,VersionedValue>> values) |
void |
Gossiper.addLocalApplicationStates(java.util.List<Pair<ApplicationState,VersionedValue>> states) |
void |
Gossiper.start(int generationNbr,
java.util.Map<ApplicationState,VersionedValue> preloadLocalStates)
Start the gossiper with the generation number, preloading the map of application states before starting
|
Modifier and Type | Method and Description |
---|---|
void |
ReconnectableSnitchHelper.beforeChange(java.net.InetAddress endpoint,
EndpointState currentState,
ApplicationState newStateKey,
VersionedValue newValue) |
void |
ReconnectableSnitchHelper.onChange(java.net.InetAddress endpoint,
ApplicationState state,
VersionedValue value) |
Modifier and Type | Method and Description |
---|---|
void |
AnticompactionTask.beforeChange(java.net.InetAddress endpoint,
EndpointState currentState,
ApplicationState newStateKey,
VersionedValue newValue) |
void |
RepairSession.beforeChange(java.net.InetAddress endpoint,
EndpointState currentState,
ApplicationState newStateKey,
VersionedValue newValue) |
void |
AnticompactionTask.onChange(java.net.InetAddress endpoint,
ApplicationState state,
VersionedValue value) |
void |
RepairSession.onChange(java.net.InetAddress endpoint,
ApplicationState state,
VersionedValue value) |
Modifier and Type | Method and Description |
---|---|
void |
ActiveRepairService.beforeChange(java.net.InetAddress endpoint,
EndpointState currentState,
ApplicationState newStateKey,
VersionedValue newValue) |
void |
LoadBroadcaster.beforeChange(java.net.InetAddress endpoint,
EndpointState currentState,
ApplicationState newStateKey,
VersionedValue newValue) |
void |
StorageService.beforeChange(java.net.InetAddress endpoint,
EndpointState currentState,
ApplicationState newStateKey,
VersionedValue newValue) |
void |
ActiveRepairService.onChange(java.net.InetAddress endpoint,
ApplicationState state,
VersionedValue value) |
void |
LoadBroadcaster.onChange(java.net.InetAddress endpoint,
ApplicationState state,
VersionedValue value) |
void |
StorageService.onChange(java.net.InetAddress endpoint,
ApplicationState state,
VersionedValue value) |
Modifier and Type | Method and Description |
---|---|
void |
StreamSession.beforeChange(java.net.InetAddress endpoint,
EndpointState currentState,
ApplicationState newStateKey,
VersionedValue newValue) |
void |
StreamSession.onChange(java.net.InetAddress endpoint,
ApplicationState state,
VersionedValue value) |
Copyright © 2020 The Apache Software Foundation