public class BambooClusterNodeHeartbeatServiceImpl extends com.atlassian.beehive.db.AbstractClusterNodeHeartbeatService implements BambooClusterNodeHeartbeatService
Modifier and Type | Field and Description |
---|---|
static int |
MAX_TIME_WITHOUT_LOCK_MINUTES |
Constructor and Description |
---|
BambooClusterNodeHeartbeatServiceImpl(ClusterNodeHeartbeatBootstrapDao clusterNodeHeartBeatDao,
ClusterLockBootstrapDao clusterLockBootstrapDao,
BambooLicenseManager bambooLicenseManager) |
Modifier and Type | Method and Description |
---|---|
List<BambooNodeStatus> |
getNodeStatuses()
Get status of all nodes if DC license applied otherwise empty list.
|
boolean |
isCurrentNodePrimaryBuffered() |
boolean |
isNodeHeartbeatStarted() |
protected com.atlassian.scheduler.JobRunner |
newHeartbeatJobRunner() |
void |
setCurrentNodePrimary(boolean primary)
Set current node's primary flag.
|
void |
startNodeHeartbeat()
Starts registering heartbeats for the current node.
|
findLiveNodes, findLiveNodes, getLastHeartbeatTime, getNodeId, isNodeLive, startHeartbeat
@Inject public BambooClusterNodeHeartbeatServiceImpl(@NotNull ClusterNodeHeartbeatBootstrapDao clusterNodeHeartBeatDao, @NotNull ClusterLockBootstrapDao clusterLockBootstrapDao, @NotNull BambooLicenseManager bambooLicenseManager) throws com.atlassian.scheduler.SchedulerServiceException
com.atlassian.scheduler.SchedulerServiceException
public void startNodeHeartbeat() throws Exception
BambooClusterNodeHeartbeatService
startNodeHeartbeat
in interface BambooClusterNodeHeartbeatService
Exception
public boolean isNodeHeartbeatStarted()
isNodeHeartbeatStarted
in interface BambooClusterNodeHeartbeatService
public void setCurrentNodePrimary(boolean primary)
BambooClusterNodeHeartbeatService
setCurrentNodePrimary
in interface BambooClusterNodeHeartbeatService
public boolean isCurrentNodePrimaryBuffered()
isCurrentNodePrimaryBuffered
in interface BambooClusterNodeHeartbeatService
@NotNull public List<BambooNodeStatus> getNodeStatuses()
BambooClusterNodeHeartbeatService
getNodeStatuses
in interface BambooClusterNodeHeartbeatService
protected com.atlassian.scheduler.JobRunner newHeartbeatJobRunner()
newHeartbeatJobRunner
in class com.atlassian.beehive.db.AbstractClusterNodeHeartbeatService
Copyright © 2021 Atlassian Software Systems Pty Ltd. All rights reserved.