Package com.atlassian.bamboo.beehive

Class BambooClusterNodeHeartBeatRawJdbcDao

java.lang.Object

com.atlassian.bamboo.beehive.AbstractBambooRawJdbcDao

com.atlassian.bamboo.beehive.BambooClusterNodeHeartBeatRawJdbcDao

All Implemented Interfaces:

ClusterNodeHeartbeatDao

public class BambooClusterNodeHeartBeatRawJdbcDao
extends AbstractBambooRawJdbcDao
implements ClusterNodeHeartbeatDao

Field Summary

Fields

Modifier and Type	Field	Description
static final int	NODE_HOSTNAME_MAX_LENGTH
static final int	NODE_ID_MAX_LENGTH
static final int	NODE_NAME_MAX_LENGTH
static final String	TABLE_NAME

Fields inherited from class com.atlassian.bamboo.beehive.AbstractBambooRawJdbcDao

dbmsBean, hibernateConfig

Constructor Summary

Constructors

Constructor	Description
BambooClusterNodeHeartBeatRawJdbcDao()

Method Summary

Modifier and Type	Method	Description
void	deleteNode(@NotNull String nodeId)	Remove node by the given id.
void	ensureNodeHeartbeatTableExists()	Creates heartbeat table if required.
List<BambooNodeStatus>	findAll()	Get all heartbeats.
@NotNull List<BambooNodeInfo>	findAllNodesInfo()	Get all present in the database nodes together with their heartbeats.
@NotNull List<BambooNodeInfo>	findNodesInfoWithHeartbeatsAfter(long time)	Get all nodes in the database together with their heartbeats in the time window specified by the time argument.
@NotNull Collection<String>	findNodesWithHeartbeatsAfter(long time)
@Nullable Long	getLastHeartbeatTime(@NotNull String nodeId)	Returns the last time a heartbeat was sent by the given node.
@NotNull String	getNodeId()	Returns the globally unique Identifier for this cluster node.
void	writeHeartBeat(long time)	Writes a heartbeat for this node at the given time.

Methods inherited from class com.atlassian.bamboo.beehive.AbstractBambooRawJdbcDao

ensureClusterTableExists, supplierWithConnection, withDatabaseConnection

Methods inherited from class java.lang.Object

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

Field Details

NODE_ID_MAX_LENGTH

public static final int NODE_ID_MAX_LENGTH

See Also:

• Constant Field Values

NODE_NAME_MAX_LENGTH

public static final int NODE_NAME_MAX_LENGTH

See Also:

• Constant Field Values

NODE_HOSTNAME_MAX_LENGTH

public static final int NODE_HOSTNAME_MAX_LENGTH

See Also:

• Constant Field Values

TABLE_NAME

public static final String TABLE_NAME

See Also:

• Constant Field Values

Constructor Details

BambooClusterNodeHeartBeatRawJdbcDao

public BambooClusterNodeHeartBeatRawJdbcDao()

Method Details

getNodeId

@NotNull
public @NotNull String getNodeId()

Description copied from interface: ClusterNodeHeartbeatDao

Returns the globally unique Identifier for this cluster node.

Specified by:

getNodeId in interface ClusterNodeHeartbeatDao

Returns:

the globally unique Identifier for this cluster node.

writeHeartBeat

public void writeHeartBeat(long time)

Description copied from interface: ClusterNodeHeartbeatDao

Writes a heartbeat for this node at the given time. Caller will pass the time to stamp; in production this would normally be System.currentTimeMillis().

Specified by:

writeHeartBeat in interface ClusterNodeHeartbeatDao

Parameters:

time - the time in millis to write as the heartbeat.

getLastHeartbeatTime

@Nullable
public @Nullable Long getLastHeartbeatTime(@NotNull
 @NotNull String nodeId)

Description copied from interface: ClusterNodeHeartbeatDao

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

A null value indicates no heartbeats have been sent by this node.

Specified by:

getLastHeartbeatTime in interface ClusterNodeHeartbeatDao

Parameters:

nodeId - the node

Returns:

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

findNodesWithHeartbeatsAfter

@NotNull
public @NotNull Collection<String> findNodesWithHeartbeatsAfter(long time)

Specified by:

findNodesWithHeartbeatsAfter in interface ClusterNodeHeartbeatDao

findNodesInfoWithHeartbeatsAfter

@NotNull
public @NotNull List<BambooNodeInfo> findNodesInfoWithHeartbeatsAfter(long time)

Description copied from interface: ClusterNodeHeartbeatDao

Get all nodes in the database together with their heartbeats in the time window specified by the time argument.

Specified by:

findNodesInfoWithHeartbeatsAfter in interface ClusterNodeHeartbeatDao

Parameters:

time - the time in millis specifying the time window for the query

Returns:

list of nodes

findAll

public List<BambooNodeStatus> findAll()

Description copied from interface: ClusterNodeHeartbeatDao

Get all heartbeats. The information about nodes' primary and alive attributes is not accurate.

Specified by:

findAll in interface ClusterNodeHeartbeatDao

findAllNodesInfo

@NotNull
public @NotNull List<BambooNodeInfo> findAllNodesInfo()

Description copied from interface: ClusterNodeHeartbeatDao

Get all present in the database nodes together with their heartbeats.

Specified by:

findAllNodesInfo in interface ClusterNodeHeartbeatDao

Returns:

list of nodes

deleteNode

public void deleteNode(@NotNull
 @NotNull String nodeId)

Description copied from interface: ClusterNodeHeartbeatDao

Remove node by the given id.

Specified by:

deleteNode in interface ClusterNodeHeartbeatDao

ensureNodeHeartbeatTableExists

public void ensureNodeHeartbeatTableExists()

Description copied from interface: ClusterNodeHeartbeatDao

Creates heartbeat table if required.

Specified by:

ensureNodeHeartbeatTableExists in interface ClusterNodeHeartbeatDao