public class NoOpClusterHeartbeatManager extends Object implements ClusterHeartbeatManager
Constructor and Description |
---|
NoOpClusterHeartbeatManager() |
Modifier and Type | Method and Description |
---|---|
Collection<ClusterHeartbeatEntity> |
findHeartbeatsAfter(long timestamp) |
Collection<String> |
findNodesWithHeartbeatsAfter(long time) |
Long |
getLastHeartbeatTime(String nodeId)
Returns the last time a heartbeat was sent by the given node.
|
String |
getNodeId()
Returns the globally unique Identifier for this cluster node.
|
int |
removeHeartbeatsBefore(long timestamp)
Removes the heartbeats that heven't reported live before the given timestamp
|
void |
writeHeartBeat(long time)
Writes a heartbeat for this node at the given time.
|
@Nonnull public String getNodeId()
ClusterNodeHeartBeatDao
getNodeId
in interface ClusterNodeHeartBeatDao
public void writeHeartBeat(long time)
ClusterNodeHeartBeatDao
System.currentTimeMillis()
.writeHeartBeat
in interface ClusterNodeHeartBeatDao
time
- the time in millis to write as the heartbeat.@Nullable public Long getLastHeartbeatTime(@Nonnull String nodeId)
ClusterNodeHeartBeatDao
A null
value indicates no heartbeats have been sent by this node.
getLastHeartbeatTime
in interface ClusterNodeHeartBeatDao
nodeId
- the node@Nonnull public Collection<String> findNodesWithHeartbeatsAfter(long time)
findNodesWithHeartbeatsAfter
in interface ClusterNodeHeartBeatDao
public Collection<ClusterHeartbeatEntity> findHeartbeatsAfter(long timestamp)
findHeartbeatsAfter
in interface ClusterHeartbeatManager
public int removeHeartbeatsBefore(long timestamp)
ClusterHeartbeatManager
removeHeartbeatsBefore
in interface ClusterHeartbeatManager
Copyright © 2024 Atlassian. All rights reserved.