com.atlassian.bamboo.beehive

Class BambooClusterNodeHeartbeatServiceImpl

java.lang.Object

com.atlassian.bamboo.beehive.BambooClusterNodeHeartbeatServiceImpl

All Implemented Interfaces:

BambooClusterNodeHeartbeatService

public class BambooClusterNodeHeartbeatServiceImpl
extends Object
implements BambooClusterNodeHeartbeatService

Field Summary

Fields

Modifier and Type	Field and Description
static int	MAX_TIME_WITHOUT_LOCK_MINUTES

Constructor Summary

Constructors

Constructor and Description
BambooClusterNodeHeartbeatServiceImpl(@NotNull ClusterNodeHeartbeatBootstrapDao clusterNodeHeartBeatDao, @NotNull ClusterLockBootstrapDao clusterLockBootstrapDao, @NotNull BambooLicenseManager bambooLicenseManager)

Method Summary

Modifier and Type	Method and Description
@NotNull Collection<String>	findLiveNodes()
@NotNull Collection<String>	findLiveNodes(long threshold)
Long	getLastHeartbeatTime(@NotNull String nodeId)
@NotNull String	getNodeId()
@NotNull List<BambooNodeStatus>	getNodeStatuses()
boolean	isCurrentNodePrimaryBuffered()
boolean	isNodeHeartbeatStarted()
boolean	isNodeLive(@NotNull String nodeId)
protected com.atlassian.scheduler.JobRunner	newHeartbeatJobRunner()
void	setCurrentNodePrimary(boolean primary)
void	shutdown()
void	startNodeHeartbeat()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

MAX_TIME_WITHOUT_LOCK_MINUTES

public static final int MAX_TIME_WITHOUT_LOCK_MINUTES

Constructor Detail

BambooClusterNodeHeartbeatServiceImpl

@Inject
public BambooClusterNodeHeartbeatServiceImpl(@NotNull
                                                     @NotNull ClusterNodeHeartbeatBootstrapDao clusterNodeHeartBeatDao,
                                                     @NotNull
                                                     @NotNull ClusterLockBootstrapDao clusterLockBootstrapDao,
                                                     @NotNull
                                                     @NotNull BambooLicenseManager bambooLicenseManager)
                                              throws com.atlassian.scheduler.SchedulerServiceException

Throws:

com.atlassian.scheduler.SchedulerServiceException

Method Detail

startNodeHeartbeat

public void startNodeHeartbeat()
                        throws Exception

Specified by:

startNodeHeartbeat in interface BambooClusterNodeHeartbeatService

Throws:

Exception

getNodeId

@NotNull
public @NotNull String getNodeId()

Specified by:

getNodeId in interface BambooClusterNodeHeartbeatService

isNodeLive

public boolean isNodeLive(@NotNull
                          @NotNull String nodeId)

Specified by:

isNodeLive in interface BambooClusterNodeHeartbeatService

getLastHeartbeatTime

public Long getLastHeartbeatTime(@NotNull
                                 @NotNull String nodeId)

Specified by:

getLastHeartbeatTime in interface BambooClusterNodeHeartbeatService

findLiveNodes

@NotNull
public @NotNull Collection<String> findLiveNodes()

Specified by:

findLiveNodes in interface BambooClusterNodeHeartbeatService

findLiveNodes

@NotNull
public @NotNull Collection<String> findLiveNodes(long threshold)

Specified by:

findLiveNodes in interface BambooClusterNodeHeartbeatService

isNodeHeartbeatStarted

public boolean isNodeHeartbeatStarted()

Specified by:

isNodeHeartbeatStarted in interface BambooClusterNodeHeartbeatService

setCurrentNodePrimary

public void setCurrentNodePrimary(boolean primary)

Specified by:

setCurrentNodePrimary in interface BambooClusterNodeHeartbeatService

isCurrentNodePrimaryBuffered

public boolean isCurrentNodePrimaryBuffered()

Specified by:

isCurrentNodePrimaryBuffered in interface BambooClusterNodeHeartbeatService

getNodeStatuses

@NotNull
public @NotNull List<BambooNodeStatus> getNodeStatuses()

Specified by:

getNodeStatuses in interface BambooClusterNodeHeartbeatService

newHeartbeatJobRunner

protected com.atlassian.scheduler.JobRunner newHeartbeatJobRunner()

shutdown

public void shutdown()

Specified by:

shutdown in interface BambooClusterNodeHeartbeatService