public class BambooClusterNodeHeartBeatRawJdbcDao extends AbstractBambooRawJdbcDao implements ClusterNodeHeartbeatBootstrapDao
Modifier and Type | Field and Description |
---|---|
static int |
NODE_ID_MAX_LENGTH |
static int |
NODE_NAME_MAX_LENGTH |
dbmsBean, hibernateConfig, postBoostrap
Constructor and Description |
---|
BambooClusterNodeHeartBeatRawJdbcDao() |
Modifier and Type | Method and Description |
---|---|
void |
ensureNodeHeartbeatTableExists()
Creates heartbeat table if required.
|
List<BambooNodeStatus> |
findAll()
Get all heartbeats.
|
Collection<String> |
findNodesWithHeartbeatsAfter(long time) |
Long |
getLastHeartbeatTime(String nodeId) |
String |
getNodeId() |
void |
writeHeartBeat(long time) |
contextDestroyed, contextInitialized, ensureClusterTableExists, supplierWithConnection, withDatabaseConnection
public static final int NODE_ID_MAX_LENGTH
public static final int NODE_NAME_MAX_LENGTH
public BambooClusterNodeHeartBeatRawJdbcDao()
@NotNull public String getNodeId()
getNodeId
in interface com.atlassian.beehive.db.spi.ClusterNodeHeartBeatDao
public void writeHeartBeat(long time)
writeHeartBeat
in interface com.atlassian.beehive.db.spi.ClusterNodeHeartBeatDao
@Nullable public Long getLastHeartbeatTime(@NotNull String nodeId)
getLastHeartbeatTime
in interface com.atlassian.beehive.db.spi.ClusterNodeHeartBeatDao
@NotNull public Collection<String> findNodesWithHeartbeatsAfter(long time)
findNodesWithHeartbeatsAfter
in interface com.atlassian.beehive.db.spi.ClusterNodeHeartBeatDao
public List<BambooNodeStatus> findAll()
ClusterNodeHeartbeatBootstrapDao
findAll
in interface ClusterNodeHeartbeatBootstrapDao
public void ensureNodeHeartbeatTableExists()
ClusterNodeHeartbeatBootstrapDao
ensureNodeHeartbeatTableExists
in interface ClusterNodeHeartbeatBootstrapDao
Copyright © 2021 Atlassian Software Systems Pty Ltd. All rights reserved.