A B C D F G H I N R S T U W

A

AbstractClusterLockServiceTckTest - Class in com.atlassian.beehive

Generic tests that should be able to be run on any implementation of ClusterLockService as a Technology Compatibility Kit (TCK).

AbstractClusterLockServiceTckTest() - Constructor for class com.atlassian.beehive.AbstractClusterLockServiceTckTest

AbstractClusterLockServiceTckTest.TestThread - Class in com.atlassian.beehive

A test thread that encapsulates most of the logic associated with verifying cluster lock behaviour.

AbstractClusterLockServiceTckTest.TestThread(int, String, int, int) - Constructor for class com.atlassian.beehive.AbstractClusterLockServiceTckTest.TestThread

AbstractClusterNodeHeartbeatService - Class in com.atlassian.beehive

Implementation of ClusterNodeHeartbeatService.

AbstractClusterNodeHeartbeatService(ClusterNodeHeartBeatDao, SchedulerService) - Constructor for class com.atlassian.beehive.AbstractClusterNodeHeartbeatService

await() - Method in class com.atlassian.beehive.Barrier

await(long) - Method in class com.atlassian.beehive.Barrier

B

Barrier - Class in com.atlassian.beehive

A simple one-shot event barrier that can last at most the requested number of seconds.

Barrier() - Constructor for class com.atlassian.beehive.Barrier

C

cleanUpOrphanLocks() - Method in class com.atlassian.beehive.DatabaseClusterLockService

ClusterLock - Interface in com.atlassian.beehive

Represents a cluster-wide lock.

ClusterLockDao - Interface in com.atlassian.beehive.spi

Provides access to the Cluster Lock DB table.

clusterLockService - Variable in class com.atlassian.beehive.AbstractClusterLockServiceTckTest

ClusterLockService - Interface in com.atlassian.beehive

Provides methods for running code under a cluster-wide lock.

ClusterLockStatus - Class in com.atlassian.beehive.spi

ClusterLockStatus(String, String, long) - Constructor for class com.atlassian.beehive.spi.ClusterLockStatus

ClusterNodeHeartBeatDao - Interface in com.atlassian.beehive.spi

Clustered applications need to implement this DAO in order to be able to use the DatabaseClusterLockService.

ClusterNodeHeartbeatService - Interface in com.atlassian.beehive

Provides a heartbeat for nodes of a cluster and utility methods for finding out about the "liveness" of other nodes.

com.atlassian.beehive - package com.atlassian.beehive

com.atlassian.beehive.hazelcast - package com.atlassian.beehive.hazelcast

com.atlassian.beehive.spi - package com.atlassian.beehive.spi

createClusterLockService() - Method in class com.atlassian.beehive.AbstractClusterLockServiceTckTest

D

DatabaseClusterLockService - Class in com.atlassian.beehive

This is the database backed implementation of ClusterLockService that can be used by clustered applications.

DatabaseClusterLockService(ClusterLockDao, ClusterNodeHeartbeatService) - Constructor for class com.atlassian.beehive.DatabaseClusterLockService

DEFAULT_TIMEOUT - Static variable in class com.atlassian.beehive.Barrier

The default timeout that will be used by Barrier.await().

deleteLocksHeldByNode(String) - Method in interface com.atlassian.beehive.spi.ClusterLockDao

Deletes any locks held by the given node.

F

findLiveNodes() - Method in class com.atlassian.beehive.AbstractClusterNodeHeartbeatService

findLiveNodes(long) - Method in class com.atlassian.beehive.AbstractClusterNodeHeartbeatService

findLiveNodes() - Method in interface com.atlassian.beehive.ClusterNodeHeartbeatService

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

findLiveNodes(long) - Method in interface com.atlassian.beehive.ClusterNodeHeartbeatService

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

findNodesWithHeartbeatsAfter(long) - Method in interface com.atlassian.beehive.spi.ClusterNodeHeartBeatDao

G

getClusterLockStatusByName(String) - Method in interface com.atlassian.beehive.spi.ClusterLockDao

Returns the cluster lock details for the given name, or null if no such lock has ever been created.

getLastHeartbeatTime(String) - Method in class com.atlassian.beehive.AbstractClusterNodeHeartbeatService

getLastHeartbeatTime(String) - Method in interface com.atlassian.beehive.ClusterNodeHeartbeatService

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

getLastHeartbeatTime(String) - Method in interface com.atlassian.beehive.spi.ClusterNodeHeartBeatDao

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

getLockedByNode() - Method in class com.atlassian.beehive.spi.ClusterLockStatus

getLockForName(String) - Method in interface com.atlassian.beehive.ClusterLockService

Returns the cluster-wide lock for the given name.

getLockForName(String) - Method in class com.atlassian.beehive.DatabaseClusterLockService

getLockForName(String) - Method in class com.atlassian.beehive.hazelcast.HazelcastClusterLockService

getLockForName(String) - Method in class com.atlassian.beehive.SimpleClusterLockService

getLockName() - Method in class com.atlassian.beehive.spi.ClusterLockStatus

getNodeId() - Method in class com.atlassian.beehive.AbstractClusterNodeHeartbeatService

getNodeId() - Method in interface com.atlassian.beehive.ClusterNodeHeartbeatService

Returns the node ID for this node.

getNodeId() - Method in interface com.atlassian.beehive.spi.ClusterNodeHeartBeatDao

Returns the globally unique Identifier for this cluster node.

getUpdateTime() - Method in class com.atlassian.beehive.spi.ClusterLockStatus

H

HazelcastClusterLockService - Class in com.atlassian.beehive.hazelcast

Hazelcast implementation of ClusterLockService

HazelcastClusterLockService(HazelcastInstance) - Constructor for class com.atlassian.beehive.hazelcast.HazelcastClusterLockService

I

insertEmptyClusterLock(String, long) - Method in interface com.atlassian.beehive.spi.ClusterLockDao

Attempt to insert an "unlocked" DB row for the named lock.

isHeldByCurrentThread() - Method in interface com.atlassian.beehive.ClusterLock

Queries if this lock is held by the current thread.

isNodeLive(String) - Method in class com.atlassian.beehive.AbstractClusterNodeHeartbeatService

isNodeLive(String) - Method in interface com.atlassian.beehive.ClusterNodeHeartbeatService

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

N

newCondition() - Method in interface com.atlassian.beehive.ClusterLock

This optional operation from the java Lock interface is not supported in ClusterLock.

R

run() - Method in class com.atlassian.beehive.AbstractClusterLockServiceTckTest.TestThread

Executes the basic sequence described in the class description.

runTest() - Method in class com.atlassian.beehive.AbstractClusterLockServiceTckTest.TestThread

The implementation of the basic sequence described in the class documentation.

runTestThreads(AbstractClusterLockServiceTckTest.TestThread...) - Method in class com.atlassian.beehive.AbstractClusterLockServiceTckTest

S

signal() - Method in class com.atlassian.beehive.Barrier

SimpleClusterLockService - Class in com.atlassian.beehive

Simple implementation of ClusterLockService that works for a single node application.

SimpleClusterLockService() - Constructor for class com.atlassian.beehive.SimpleClusterLockService

startHeartbeat() - Method in class com.atlassian.beehive.AbstractClusterNodeHeartbeatService

The concrete class must ensure that this is called upon product startup, but after the DB is available.

T

test_runWithLock_differentLockNames() - Method in class com.atlassian.beehive.AbstractClusterLockServiceTckTest

test_runWithLock_doInterrupt() - Method in class com.atlassian.beehive.AbstractClusterLockServiceTckTest

test_runWithLock_reentrancy() - Method in class com.atlassian.beehive.AbstractClusterLockServiceTckTest

test_runWithLock_sameLockNames() - Method in class com.atlassian.beehive.AbstractClusterLockServiceTckTest

test_runWithLockInterruptibly_doInterrupt() - Method in class com.atlassian.beehive.AbstractClusterLockServiceTckTest

test_tryRunWithLock_acquireLater() - Method in class com.atlassian.beehive.AbstractClusterLockServiceTckTest

test_tryRunWithLock_no_acquire() - Method in class com.atlassian.beehive.AbstractClusterLockServiceTckTest

tryUpdateAcquireLock(String, String, long) - Method in interface com.atlassian.beehive.spi.ClusterLockDao

Attempt to acquire an existing named lock for the given nodeId.

U

unlock(String, String, long) - Method in interface com.atlassian.beehive.spi.ClusterLockDao

Unlock the named lock, if this node still holds the lock.

W

writeHeartBeat(long) - Method in interface com.atlassian.beehive.spi.ClusterNodeHeartBeatDao

Writes a heartbeat for this node at the given time.

A B C D F G H I N R S T U W