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
org.apache.cassandra.streaming

Uses of EndpointState in org.apache.cassandra.gms

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

Modifier and Type	Field	Description
java.util.concurrent.ConcurrentMap<InetAddressAndPort,EndpointState>	Gossiper.endpointStateMap
static IVersionedSerializer<EndpointState>	EndpointState.nullableSerializer
static 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)

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

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

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)
boolean	Gossiper.isAdministrativelyInactiveState(EndpointState epState)
boolean	Gossiper.isDeadState(EndpointState epState)
boolean	Gossiper.isSilentShutdownState(EndpointState epState)
boolean	EndpointState.isSupersededBy(EndpointState that)
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(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)
void	Gossiper.notifyFailureDetector(java.util.Map<InetAddressAndPort,EndpointState> remoteEpStateMap)
boolean	Gossiper.sufficientForStartupSafetyCheck(java.util.Map<InetAddressAndPort,EndpointState> epStateMap)

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

Constructor	Description
EndpointState(EndpointState other)

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(TableId tableId, java.util.Collection<InetAddressAndPort> endpoints, EndpointState localEpState, java.util.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

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

Uses of EndpointState in org.apache.cassandra.streaming

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

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