net.greghaines.jesque.meta.dao.impl

Class WorkerInfoDAORedisImpl

java.lang.Object

net.greghaines.jesque.meta.dao.impl.WorkerInfoDAORedisImpl

All Implemented Interfaces:

WorkerInfoDAO

public class WorkerInfoDAORedisImpl
extends Object
implements WorkerInfoDAO

WorkerInfoDAORedisImpl gets worker information from Redis.

Author:

Greg Haines

Constructor Summary

Constructors

Constructor and Description
WorkerInfoDAORedisImpl(Config config, redis.clients.util.Pool<redis.clients.jedis.Jedis> jedisPool) Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
protected WorkerInfo	createWorker(String workerName, redis.clients.jedis.Jedis jedis)
long	getActiveWorkerCount()
List<WorkerInfo>	getActiveWorkers()
List<WorkerInfo>	getAllWorkers()
long	getPausedWorkerCount()
List<WorkerInfo>	getPausedWorkers()
WorkerInfo	getWorker(String workerName)
long	getWorkerCount()
Map<String,List<WorkerInfo>>	getWorkerHostMap()
protected boolean	isWorkerInState(String workerName, WorkerInfo.State requestedState, redis.clients.jedis.Jedis jedis)
void	removeWorker(String workerName) Removes the metadata about a worker.

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkerInfoDAORedisImpl

public WorkerInfoDAORedisImpl(Config config,
                      redis.clients.util.Pool<redis.clients.jedis.Jedis> jedisPool)

Constructor.

Parameters:

config - the Jesque configuration

jedisPool - the pool of Jedis connections

Method Detail

getWorkerCount

public long getWorkerCount()

Specified by:

getWorkerCount in interface WorkerInfoDAO

Returns:

total number of workers known

getActiveWorkerCount

public long getActiveWorkerCount()

Specified by:

getActiveWorkerCount in interface WorkerInfoDAO

Returns:

number of active workers

getPausedWorkerCount

public long getPausedWorkerCount()

Specified by:

getPausedWorkerCount in interface WorkerInfoDAO

Returns:

number of paused workers

getActiveWorkers

public List<WorkerInfo> getActiveWorkers()

Specified by:

getActiveWorkers in interface WorkerInfoDAO

Returns:

information about all active workers

getPausedWorkers

public List<WorkerInfo> getPausedWorkers()

Specified by:

getPausedWorkers in interface WorkerInfoDAO

Returns:

information about all paused workers

getAllWorkers

public List<WorkerInfo> getAllWorkers()

Specified by:

getAllWorkers in interface WorkerInfoDAO

Returns:

information about all workers

getWorker

public WorkerInfo getWorker(String workerName)

Specified by:

getWorker in interface WorkerInfoDAO

Parameters:

workerName - the name of the worker

Returns:

information about the given worker or null if that worker does not exist

getWorkerHostMap

public Map<String,List<WorkerInfo>> getWorkerHostMap()

Specified by:

getWorkerHostMap in interface WorkerInfoDAO

Returns:

a map of worker informations by hostname

createWorker

protected WorkerInfo createWorker(String workerName,
                      redis.clients.jedis.Jedis jedis)
                           throws ParseException,
                                  IOException

Throws:

ParseException

IOException

removeWorker

public void removeWorker(String workerName)

Removes the metadata about a worker.

Specified by:

removeWorker in interface WorkerInfoDAO

Parameters:

workerName - The worker name to remove

isWorkerInState

protected boolean isWorkerInState(String workerName,
                      WorkerInfo.State requestedState,
                      redis.clients.jedis.Jedis jedis)
                           throws IOException

Throws:

IOException