Modifier and Type | Field and Description |
---|---|
static IVersionedSerializer<EndpointState> |
EndpointState.serializer |
Modifier and Type | Method and Description |
---|---|
EndpointState |
Gossiper.getEndpointStateForEndpoint(InetAddressAndPort ep) |
Modifier and Type | Method and Description |
---|---|
java.util.Map<InetAddressAndPort,EndpointState> |
Gossiper.doShadowRound() |
java.util.Map<InetAddressAndPort,EndpointState> |
Gossiper.doShadowRound(java.util.Set<InetAddressAndPort> peers)
Do a single 'shadow' round of gossip by retrieving endpoint states that will be stored exclusively in the
map return value, instead of endpointStateMap.
|
Modifier and Type | Method and Description |
---|---|
default void |
IEndpointStateChangeSubscriber.beforeChange(InetAddressAndPort endpoint,
EndpointState currentState,
ApplicationState newStateKey,
VersionedValue newValue) |
boolean |
Gossiper.isAdministrativelyInactiveState(EndpointState epState) |
boolean |
Gossiper.isDeadState(EndpointState epState) |
boolean |
Gossiper.isSilentShutdownState(EndpointState epState) |
void |
Gossiper.markDead(InetAddressAndPort addr,
EndpointState localState) |
default void |
IEndpointStateChangeSubscriber.onAlive(InetAddressAndPort endpoint,
EndpointState state) |
default void |
IEndpointStateChangeSubscriber.onDead(InetAddressAndPort endpoint,
EndpointState state) |
default void |
IEndpointStateChangeSubscriber.onJoin(InetAddressAndPort endpoint,
EndpointState epState)
Use to inform interested parties about the change in the state
for specified endpoint
|
default void |
IEndpointStateChangeSubscriber.onRestart(InetAddressAndPort endpoint,
EndpointState state)
Called whenever a node is restarted.
|
void |
Gossiper.realMarkAlive(InetAddressAndPort addr,
EndpointState localState) |
Modifier and Type | Method and Description |
---|---|
void |
Gossiper.applyStateLocally(java.util.Map<InetAddressAndPort,EndpointState> epStateMap) |
java.util.UUID |
Gossiper.getHostId(InetAddressAndPort endpoint,
java.util.Map<InetAddressAndPort,EndpointState> epStates) |
boolean |
Gossiper.isSafeForStartup(InetAddressAndPort endpoint,
java.util.UUID localHostUUID,
boolean isBootstrapping,
java.util.Map<InetAddressAndPort,EndpointState> epStates)
Check if this node can safely be started and join the ring.
|
protected void |
Gossiper.maybeFinishShadowRound(InetAddressAndPort respondent,
boolean isInShadowRound,
java.util.Map<InetAddressAndPort,EndpointState> epStateMap) |
boolean |
Gossiper.sufficientForStartupSafetyCheck(java.util.Map<InetAddressAndPort,EndpointState> epStateMap) |
Constructor and Description |
---|
EndpointState(EndpointState other) |
Modifier and Type | Method and Description |
---|---|
void |
ReconnectableSnitchHelper.beforeChange(InetAddressAndPort endpoint,
EndpointState currentState,
ApplicationState newStateKey,
VersionedValue newValue) |
void |
ReconnectableSnitchHelper.onAlive(InetAddressAndPort endpoint,
EndpointState state) |
void |
ReconnectableSnitchHelper.onDead(InetAddressAndPort endpoint,
EndpointState state) |
void |
ReconnectableSnitchHelper.onJoin(InetAddressAndPort endpoint,
EndpointState epState) |
void |
ReconnectableSnitchHelper.onRestart(InetAddressAndPort endpoint,
EndpointState state) |
Modifier and Type | Method and Description |
---|---|
void |
RepairSession.onRestart(InetAddressAndPort endpoint,
EndpointState epState) |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.Future<java.lang.Void> |
MigrationCoordinator.reportEndpointVersion(InetAddressAndPort endpoint,
EndpointState state) |
Modifier and Type | Method and Description |
---|---|
void |
ActiveRepairService.beforeChange(InetAddressAndPort endpoint,
EndpointState currentState,
ApplicationState newStateKey,
VersionedValue newValue) |
void |
StorageService.beforeChange(InetAddressAndPort endpoint,
EndpointState currentState,
ApplicationState newStateKey,
VersionedValue newValue) |
void |
ActiveRepairService.onAlive(InetAddressAndPort endpoint,
EndpointState state) |
void |
StorageService.onAlive(InetAddressAndPort endpoint,
EndpointState state) |
void |
ActiveRepairService.onDead(InetAddressAndPort endpoint,
EndpointState state) |
void |
StorageService.onDead(InetAddressAndPort endpoint,
EndpointState state) |
void |
ActiveRepairService.onJoin(InetAddressAndPort endpoint,
EndpointState epState) |
void |
LoadBroadcaster.onJoin(InetAddressAndPort endpoint,
EndpointState epState) |
void |
StorageService.onJoin(InetAddressAndPort endpoint,
EndpointState epState) |
void |
ActiveRepairService.onRestart(InetAddressAndPort endpoint,
EndpointState state) |
void |
StorageService.onRestart(InetAddressAndPort endpoint,
EndpointState state) |
Modifier and Type | Method and Description |
---|---|
void |
StreamSession.onRestart(InetAddressAndPort endpoint,
EndpointState epState) |
Copyright © 2009-2022 The Apache Software Foundation