org.hobbit.controller.queue

Class ExperimentQueueImpl

java.lang.Object

org.hobbit.controller.queue.ExperimentQueueImpl

All Implemented Interfaces:

Closeable, AutoCloseable, ExperimentQueue

public class ExperimentQueueImpl
extends Object
implements ExperimentQueue, Closeable

Created by Timofey Ermilov on 07/09/16. TODO: 1. Setup Redis-based queue for normal experiments 2. Setup Redis-based queue for challenge experiments 3. Way to get next task in queue, prioritise challenges if challenge.startTime = now

Field Summary

Fields

Modifier and Type	Field and Description
static String	CHALLENGE_KEY
static String	CHALLENGE_QUEUE
static String	EXPERIMENT_KEY
static String	EXPERIMENT_QUEUE
private static org.slf4j.Logger	LOGGER
private com.lambdaworks.redis.RedisClient	redisClient
private com.lambdaworks.redis.api.StatefulRedisConnection<String,String>	redisConnection
private com.lambdaworks.redis.api.sync.RedisCommands<String,String>	redisSyncCommands

Constructor Summary

Constructors

Constructor and Description
ExperimentQueueImpl()

Method Summary

Modifier and Type	Method and Description
void	add(ExperimentConfiguration experiment) Adds the given experiment to the queue.
void	close()
private ExperimentConfiguration	decodeExperimentFromString(String json)
ExperimentConfiguration	getExperiment(String experimentId) Retrieves the experiment configuration with the given experiment id.
ExperimentConfiguration	getNextExperiment() Returns the experiment that should be executed next.
List<ExperimentConfiguration>	listAll() Returns the list of all experiments waiting in this queue.
boolean	remove(ExperimentConfiguration experiment) Removes the experiment from the queue.
private List<ExperimentConfiguration>	stringMapToExperimentList(Map<String,String> entries)

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

private static final org.slf4j.Logger LOGGER

CHALLENGE_KEY

public static final String CHALLENGE_KEY

See Also:

Constant Field Values

EXPERIMENT_KEY

public static final String EXPERIMENT_KEY

See Also:

Constant Field Values

CHALLENGE_QUEUE

public static final String CHALLENGE_QUEUE

See Also:

Constant Field Values

EXPERIMENT_QUEUE

public static final String EXPERIMENT_QUEUE

See Also:

Constant Field Values

redisClient

private com.lambdaworks.redis.RedisClient redisClient

redisConnection

private com.lambdaworks.redis.api.StatefulRedisConnection<String,String> redisConnection

redisSyncCommands

private com.lambdaworks.redis.api.sync.RedisCommands<String,String> redisSyncCommands

Constructor Detail

ExperimentQueueImpl

public ExperimentQueueImpl()

Method Detail

decodeExperimentFromString

private ExperimentConfiguration decodeExperimentFromString(String json)

getNextExperiment

public ExperimentConfiguration getNextExperiment()

Description copied from interface: ExperimentQueue

Returns the experiment that should be executed next.

Specified by:

getNextExperiment in interface ExperimentQueue

Returns:

the experiment that should be executed next

add

public void add(ExperimentConfiguration experiment)

Description copied from interface: ExperimentQueue

Adds the given experiment to the queue.

Specified by:

add in interface ExperimentQueue

Parameters:

experiment - the experiment that should be added

remove

public boolean remove(ExperimentConfiguration experiment)

Description copied from interface: ExperimentQueue

Removes the experiment from the queue.

Specified by:

remove in interface ExperimentQueue

Parameters:

experiment - the experiment that should be removed from the queue

Returns:

true if the given experiment has been removed

stringMapToExperimentList

private List<ExperimentConfiguration> stringMapToExperimentList(Map<String,String> entries)

listAll

public List<ExperimentConfiguration> listAll()

Description copied from interface: ExperimentQueue

Returns the list of all experiments waiting in this queue.

Specified by:

listAll in interface ExperimentQueue

Returns:

the list of all experiments waiting in this queue

getExperiment

public ExperimentConfiguration getExperiment(String experimentId)

Description copied from interface: ExperimentQueue

Retrieves the experiment configuration with the given experiment id.

Specified by:

getExperiment in interface ExperimentQueue

Parameters:

experimentId - the id of the experiment that should be retrieved

Returns:

the experiment configuration or null if such an experiment can not be found

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable