com.atlassian.jira.cluster.lock

Class StartableClusterNodeHeartbeatService

java.lang.Object

com.atlassian.jira.cluster.lock.StartableClusterNodeHeartbeatService

All Implemented Interfaces:

ClusterNodeHeartbeatService, Startable

public class StartableClusterNodeHeartbeatService
extends Object
implements ClusterNodeHeartbeatService, Startable

JIRA implementation of ClusterNodeHeartbeatService

Since:

6.3

Constructor Summary

Constructors

Constructor and Description
StartableClusterNodeHeartbeatService(ClusterNodeHeartBeatDao clusterNodeHeartBeatDao, HeartbeatScheduledExecutorFactory scheduledExecutorFactory, HeartbeatJob heartbeatJob, com.atlassian.core.util.Clock clock, HeartbeatSettings settings)

Method Summary

Modifier and Type	Method and Description
Collection<String>	findLiveNodes() Returns all nodes that have sent a heartbeat within the default threshold time.
Collection<String>	findLiveNodes(long threshold) Returns all nodes that have sent a heartbeat within the given threshold.
Long	getLastHeartbeatTime(String nodeId) Returns the last time a heartbeat was sent by the given node.
String	getNodeId() Returns the node ID for this node.
boolean	isNodeLive(String nodeId) Checks whether the given cluster node is considered "live".
void	start() This method will be called after the plugin system is fully initialised and all components added to the dependency injection framework.

Methods inherited from class java.lang.Object

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

Constructor Detail

StartableClusterNodeHeartbeatService

public StartableClusterNodeHeartbeatService(ClusterNodeHeartBeatDao clusterNodeHeartBeatDao,
                                            HeartbeatScheduledExecutorFactory scheduledExecutorFactory,
                                            HeartbeatJob heartbeatJob,
                                            com.atlassian.core.util.Clock clock,
                                            HeartbeatSettings settings)

Method Detail

start

public void start()
           throws Exception

Description copied from interface: Startable

This method will be called after the plugin system is fully initialised and all components added to the dependency injection framework.

Specified by:

start in interface Startable

Throws:

Exception - Allows implementations to throw an Exception.

getNodeId

@Nonnull
public String getNodeId()

Description copied from interface: ClusterNodeHeartbeatService

Returns the node ID for this node.

Specified by:

getNodeId in interface ClusterNodeHeartbeatService

Returns:

the node ID for this node.

isNodeLive

public boolean isNodeLive(@Nonnull
                          String nodeId)

Description copied from interface: ClusterNodeHeartbeatService

Checks whether the given cluster node is considered "live".

Each live node will be writing a heartbeat on a set schedule (eg once a minute). A node is considered live if it has written a heartbeat within a reasonable tolerance level (eg 5 minutes).

The tolerance level needs to be large enough to avoid certain expected slow-downs in the system including GC pauses, or just general slowness in the JVM / scheduler / network / database of the remote node.

Specified by:

isNodeLive in interface ClusterNodeHeartbeatService

Parameters:

nodeId - the cluster node to check

Returns:

true iff the given cluster node is still "live".

getLastHeartbeatTime

@Nullable
public Long getLastHeartbeatTime(@Nonnull
                                           String nodeId)

Description copied from interface: ClusterNodeHeartbeatService

Returns the last time a heartbeat was sent by the given node.

A null value indicates no heartbeats have ever been sent by the given node.

Specified by:

getLastHeartbeatTime in interface ClusterNodeHeartbeatService

Parameters:

nodeId - the node

Returns:

the last time a heartbeat was sent by the given node.

findLiveNodes

@Nonnull
public Collection<String> findLiveNodes()

Description copied from interface: ClusterNodeHeartbeatService

Returns all nodes that have sent a heartbeat within the default threshold time.

Specified by:

findLiveNodes in interface ClusterNodeHeartbeatService

Returns:

all nodes that have sent a heartbeat within the default threshold time.

See Also:

ClusterNodeHeartbeatService.findLiveNodes(long)

findLiveNodes

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

Description copied from interface: ClusterNodeHeartbeatService

Returns all nodes that have sent a heartbeat within the given threshold.

Specified by:

findLiveNodes in interface ClusterNodeHeartbeatService

Parameters:

threshold - the threshold in milliseconds

Returns:

all nodes that have sent a heartbeat within the given threshold.

See Also:

ClusterNodeHeartbeatService.findLiveNodes()