org.eclipse.smila.workermanager

Interface WorkerManager

All Known Implementing Classes:

WorkerManagerImpl

public interface WorkerManager

Administrates all (java) workers. Handles task get/finish/keepAlive and worker scale up.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	PREFIX_INTERNAL prefix for internal workers.

Method Summary

Methods

Modifier and Type	Method and Description
void	addKeepAliveListener(TaskKeepAliveListener listener)
void	addKeepAliveTask(Task task)
boolean	containsWorker(java.lang.String worker) Returns whether the given worker was successfully registered.
AnyMap	getInfo()
boolean	hasWorker(java.lang.String worker)
void	removeKeepAliveListener(TaskKeepAliveListener listener)
void	removeKeepAliveTask(Task task)
void	setKeepAliveInterval(long keepAliveCheckMillis, long keepAliveSendSeconds) for testing.
void	setScaleUpControl(ScaleUpControl scaleUpControl)

Field Detail

PREFIX_INTERNAL

static final java.lang.String PREFIX_INTERNAL

prefix for internal workers.

See Also:

Constant Field Values

Method Detail

containsWorker

boolean containsWorker(java.lang.String worker)

Returns whether the given worker was successfully registered.

setScaleUpControl

void setScaleUpControl(ScaleUpControl scaleUpControl)

Parameters:

scaleUpControl - defines scale up limit for workers

addKeepAliveListener

void addKeepAliveListener(TaskKeepAliveListener listener)

Parameters:

listener - Listener that wants to be informed about keep alive failures.

removeKeepAliveListener

void removeKeepAliveListener(TaskKeepAliveListener listener)

Parameters:

listener - Listener that no longer wants to be informed about keep alive failures.

addKeepAliveTask

void addKeepAliveTask(Task task)

Parameters:

task - task to add under keep alive control

removeKeepAliveTask

void removeKeepAliveTask(Task task)

Parameters:

task - task to remove from keep alive control

getInfo

AnyMap getInfo()

Returns:

workerManager info object.

setKeepAliveInterval

void setKeepAliveInterval(long keepAliveCheckMillis,
                        long keepAliveSendSeconds)

for testing.

Parameters:

keepAliveCheckMillis - the time interval in ms after which we check if there are tasks for keep alive.

keepAliveSendSeconds - the time interval in seconds after which keep alive is sent for a processed task

hasWorker

boolean hasWorker(java.lang.String worker)

Returns:

whether the given worker is registered or not.