Uses of Class
org.apache.cassandra.gms.EndpointState

Packages that use EndpointState

Package	Description
org.apache.cassandra.gms
org.apache.cassandra.locator
org.apache.cassandra.repair
org.apache.cassandra.schema
org.apache.cassandra.service
org.apache.cassandra.service.disk.usage
org.apache.cassandra.service.paxos.cleanup

Uses of EndpointState in org.apache.cassandra.gms

Fields in org.apache.cassandra.gms declared as EndpointState

Modifier and Type	Field	Description
final EndpointState	GossipShutdown.state

Fields in org.apache.cassandra.gms with type parameters of type EndpointState

Modifier and Type	Field	Description
final ConcurrentMap<InetAddressAndPort,EndpointState>	Gossiper.endpointStateMap
static final IVersionedSerializer<EndpointState>	EndpointState.nullableSerializer
static final IVersionedSerializer<EndpointState>	EndpointState.serializer

Methods in org.apache.cassandra.gms that return EndpointState

Modifier and Type	Method	Description
EndpointState	Gossiper.copyEndpointStateForEndpoint(InetAddressAndPort ep)
EndpointState	Gossiper.getEndpointStateForEndpoint(InetAddressAndPort ep)
EndpointState	IGossiper.getEndpointStateForEndpoint(InetAddressAndPort ep)

Methods in org.apache.cassandra.gms that return types with arguments of type EndpointState

Modifier and Type	Method	Description
Map<InetAddressAndPort,EndpointState>	Gossiper.doShadowRound()
Map<InetAddressAndPort,EndpointState>	Gossiper.doShadowRound(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.

Methods in org.apache.cassandra.gms with parameters of type EndpointState

Modifier and Type	Method	Description
default void	IEndpointStateChangeSubscriber.beforeChange(InetAddressAndPort endpoint, EndpointState currentState, ApplicationState newStateKey, VersionedValue newValue)
static String	Gossiper.getGossipStatus(EndpointState epState)
boolean	Gossiper.isAdministrativelyInactiveState(EndpointState epState)
boolean	Gossiper.isDeadState(EndpointState epState)
boolean	Gossiper.isSilentShutdownState(EndpointState epState)
boolean	EndpointState.isSupersededBy(EndpointState that)
protected void	Gossiper.markAsShutdown(InetAddressAndPort endpoint, EndpointState remoteState)	This method is used to mark a node as shutdown; that is it gracefully exited on its own and told us about it
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)

Method parameters in org.apache.cassandra.gms with type arguments of type EndpointState

Modifier and Type	Method	Description
void	Gossiper.applyStateLocally(Map<InetAddressAndPort,EndpointState> epStateMap)
void	IGossiper.applyStateLocally(Map<InetAddressAndPort,EndpointState> epStateMap)
UUID	Gossiper.getHostId(InetAddressAndPort endpoint, Map<InetAddressAndPort,EndpointState> epStates)
boolean	Gossiper.isSafeForStartup(InetAddressAndPort endpoint, UUID localHostUUID, boolean isBootstrapping, Map<InetAddressAndPort,EndpointState> epStates)	Check if this node can safely be started and join the ring.
protected void	Gossiper.maybeFinishShadowRound(InetAddressAndPort respondent, boolean isInShadowRound, Map<InetAddressAndPort,EndpointState> epStateMap)
void	Gossiper.notifyFailureDetector(Map<InetAddressAndPort,EndpointState> remoteEpStateMap)
void	IGossiper.notifyFailureDetector(Map<InetAddressAndPort,EndpointState> remoteEpStateMap)
boolean	Gossiper.sufficientForStartupSafetyCheck(Map<InetAddressAndPort,EndpointState> epStateMap)

Constructors in org.apache.cassandra.gms with parameters of type EndpointState

Modifier	Constructor	Description
	EndpointState(EndpointState other)
	GossipShutdown(EndpointState state)

Uses of EndpointState in org.apache.cassandra.locator

Methods in org.apache.cassandra.locator with parameters of type EndpointState

Modifier and Type	Method	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)

Uses of EndpointState in org.apache.cassandra.repair

Methods in org.apache.cassandra.repair with parameters of type EndpointState

Modifier and Type	Method	Description
void	RepairSession.onRestart(InetAddressAndPort endpoint, EndpointState epState)

Uses of EndpointState in org.apache.cassandra.schema

Methods in org.apache.cassandra.schema with parameters of type EndpointState

Modifier and Type	Method	Description
void	DefaultSchemaUpdateHandler.beforeChange(InetAddressAndPort endpoint, EndpointState currentState, ApplicationState newStateKey, VersionedValue newValue)
void	DefaultSchemaUpdateHandler.onAlive(InetAddressAndPort endpoint, EndpointState state)
void	DefaultSchemaUpdateHandler.onDead(InetAddressAndPort endpoint, EndpointState state)
void	DefaultSchemaUpdateHandler.onJoin(InetAddressAndPort endpoint, EndpointState epState)
void	DefaultSchemaUpdateHandler.onRestart(InetAddressAndPort endpoint, EndpointState state)

Uses of EndpointState in org.apache.cassandra.service

Methods in org.apache.cassandra.service with parameters of type EndpointState

Modifier and Type	Method	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)

Uses of EndpointState in org.apache.cassandra.service.disk.usage

Methods in org.apache.cassandra.service.disk.usage with parameters of type EndpointState

Modifier and Type	Method	Description
void	DiskUsageBroadcaster.beforeChange(InetAddressAndPort endpoint, EndpointState currentState, ApplicationState newStateKey, VersionedValue newValue)
void	DiskUsageBroadcaster.onAlive(InetAddressAndPort endpoint, EndpointState state)
void	DiskUsageBroadcaster.onDead(InetAddressAndPort endpoint, EndpointState state)
void	DiskUsageBroadcaster.onJoin(InetAddressAndPort endpoint, EndpointState epState)
void	DiskUsageBroadcaster.onRestart(InetAddressAndPort endpoint, EndpointState state)

Uses of EndpointState in org.apache.cassandra.service.paxos.cleanup

Methods in org.apache.cassandra.service.paxos.cleanup with parameters of type EndpointState

Modifier and Type	Method	Description
void	PaxosCleanupSession.beforeChange(InetAddressAndPort endpoint, EndpointState currentState, ApplicationState newStateKey, VersionedValue newValue)
void	PaxosCleanupSession.onAlive(InetAddressAndPort endpoint, EndpointState state)
void	PaxosCleanupSession.onDead(InetAddressAndPort endpoint, EndpointState state)
void	PaxosCleanupSession.onJoin(InetAddressAndPort endpoint, EndpointState epState)
void	PaxosCleanupSession.onRestart(InetAddressAndPort endpoint, EndpointState state)
static PaxosStartPrepareCleanup	PaxosStartPrepareCleanup.prepare(SharedContext ctx, TableId tableId, Collection<InetAddressAndPort> endpoints, EndpointState localEpState, Collection<Range<Token>> ranges)	We run paxos repair as part of topology changes, so we include the local endpoint state in the paxos repair prepare message to prevent racing with gossip dissemination and guarantee that every repair participant is aware of the pending ring change during repair.

Constructors in org.apache.cassandra.service.paxos.cleanup with parameters of type EndpointState

Modifier	Constructor	Description
	Request(TableId tableId, EndpointState epState, Collection<Range<Token>> ranges)