com.atlassian.bamboo.beehive

Interface ClusterNodeHeartbeatBootstrapDao

All Known Implementing Classes:

BambooClusterNodeHeartBeatRawJdbcDao

@Internal
public interface ClusterNodeHeartbeatBootstrapDao

Specialised for Bamboo.

Method Summary

Modifier and Type	Method and Description
void	ensureNodeHeartbeatTableExists() Creates heartbeat table if required.
List<BambooNodeStatus>	findAll() Get all heartbeats.
@NotNull Collection<String>	findNodesWithHeartbeatsAfter(long time)
@NotNull 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.

Method Detail

getNodeId

@NotNull
@NotNull String getNodeId()

Returns the globally unique Identifier for this cluster node.

Returns:

the globally unique Identifier for this cluster node.

writeHeartBeat

void writeHeartBeat(long time)

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().

Parameters:

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

getLastHeartbeatTime

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

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

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

Parameters:

nodeId - the node

Returns:

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

findNodesWithHeartbeatsAfter

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

findAll

List<BambooNodeStatus> findAll()

Get all heartbeats.

ensureNodeHeartbeatTableExists

void ensureNodeHeartbeatTableExists()

Creates heartbeat table if required.