Package org.apache.cassandra.gms
Class EndpointState
- java.lang.Object
-
- org.apache.cassandra.gms.EndpointState
-
public class EndpointState extends java.lang.Object
This abstraction represents both the HeartBeatState and the ApplicationState in an EndpointState instance. Any state for a given endpoint can be retrieved from this instance.
-
-
Field Summary
Fields Modifier and Type Field Description protected static org.slf4j.Logger
logger
static IVersionedSerializer<EndpointState>
serializer
-
Constructor Summary
Constructors Constructor Description EndpointState(EndpointState other)
EndpointState(HeartBeatState initialHbState)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addApplicationState(ApplicationState key, VersionedValue value)
void
addApplicationStates(java.util.Map<ApplicationState,VersionedValue> values)
void
addApplicationStates(java.util.Set<java.util.Map.Entry<ApplicationState,VersionedValue>> values)
boolean
containsApplicationState(ApplicationState key)
VersionedValue
getApplicationState(ApplicationState key)
CassandraVersion
getReleaseVersion()
java.util.UUID
getSchemaVersion()
java.lang.String
getStatus()
long
getUpdateTimestamp()
boolean
isAlive()
boolean
isEmptyWithoutStatus()
boolean
isNormalState()
boolean
isRpcReady()
java.util.Set<java.util.Map.Entry<ApplicationState,VersionedValue>>
states()
java.lang.String
toString()
-
-
-
Field Detail
-
logger
protected static final org.slf4j.Logger logger
-
serializer
public static final IVersionedSerializer<EndpointState> serializer
-
-
Constructor Detail
-
EndpointState
public EndpointState(HeartBeatState initialHbState)
-
EndpointState
public EndpointState(EndpointState other)
-
-
Method Detail
-
getApplicationState
public VersionedValue getApplicationState(ApplicationState key)
-
containsApplicationState
public boolean containsApplicationState(ApplicationState key)
-
states
public java.util.Set<java.util.Map.Entry<ApplicationState,VersionedValue>> states()
-
addApplicationState
public void addApplicationState(ApplicationState key, VersionedValue value)
-
addApplicationStates
public void addApplicationStates(java.util.Map<ApplicationState,VersionedValue> values)
-
addApplicationStates
public void addApplicationStates(java.util.Set<java.util.Map.Entry<ApplicationState,VersionedValue>> values)
-
getUpdateTimestamp
public long getUpdateTimestamp()
- Returns:
- System.nanoTime() when state was updated last time.
-
isAlive
public boolean isAlive()
-
isEmptyWithoutStatus
public boolean isEmptyWithoutStatus()
- Returns:
- true if
HeartBeatState.isEmpty()
is true and no STATUS application state exists
-
isRpcReady
public boolean isRpcReady()
-
isNormalState
public boolean isNormalState()
-
getStatus
public java.lang.String getStatus()
-
getSchemaVersion
@Nullable public java.util.UUID getSchemaVersion()
-
getReleaseVersion
@Nullable public CassandraVersion getReleaseVersion()
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-