Class WorkerUnitContainer

java.lang.Object

org.tasktide.engine.workerunit.container.WorkerUnitContainer

public class WorkerUnitContainer
extends Object

Container class to hold instances of each TaskTideWorkerUnit for their use across the engine

Method Summary

Modifier and Type	Method	Description
void	configureEngineExecutor(WorkerUnitModelType type)	Configure TaskTideExecutor for ItemTask/WorkItem.
void	configureEngineObserverChain(WorkerUnitModelType type, int timeKeeperWallTime)	Configure TaskTideEngineObserver for ItemTask/WorkItem
void	configureExecutorServices(int engineWorkers, int itemTaskThreads)	Configures the ExecutorService for both WorkItem, and ItemTask
void	configureProcessExecutor()	Configures ProcessExecutor
void	configureStreamPath(String pathString)
void	configureWorkloadTraverser(WorkerUnitModelType type)	Configure TaskTideWorkloadTraverser for ItemTask/WorkItem.
<T extends TaskTideModel<T>> TaskTideExecutor<T>	getEngineExecutor(WorkerUnitModelType type)	Fetch required TaskTideExecutor
<T extends TaskTideModel<T>> TaskTideEngineObserver<T>	getEngineObserverChain(WorkerUnitModelType type)	Fetch required TaskTideEngineObserver
<T extends TaskTideModel<T>> TaskTideWorkloadTraverser<T>	getEngineWorkloadTraverser(WorkerUnitModelType type)	Fetch required TaskTideWorkloadTraverser
static WorkerUnitContainer	getInstance()	Static accessor for worker, configuring if not already configured.
String	getJobEnvId()	Fetch job environment Id through TaskTideManagerUtility
ProcessExecutor	getProcessExecutor()	Fetch configured ProcessExecutor
Path	getStreamPath()	Get configured Path for ProcessExecutor streams, defaulting to current directory under 'tasktide-process-executor-streams'
ExecutorService	getThreadPool(WorkerUnitModelType type)	Fetch ExecutorService thread pool for asyncronous processing
static void	reset()	Reset the engine worker unit container for testing

Methods inherited from class Object

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

Method Details

getInstance

public static WorkerUnitContainer getInstance()

Static accessor for worker, configuring if not already configured. Method can be overloaded for parameters for dependencies

Returns:

WorkerUnitContainer

configureExecutorServices

public void configureExecutorServices(int engineWorkers,
 int itemTaskThreads)
                               throws TaskTideEngineCheckedException

Configures the ExecutorService for both WorkItem, and ItemTask

Parameters:

engineWorkers -

itemTaskThreads -

Throws:

TaskTideEngineCheckedException

configureEngineObserverChain

public void configureEngineObserverChain(WorkerUnitModelType type,
 int timeKeeperWallTime)
                                  throws TaskTideEngineCheckedException

Configure TaskTideEngineObserver for ItemTask/WorkItem

Parameters:

type -

timeKeeperWallTime -

Throws:

TaskTideEngineCheckedException

configureWorkloadTraverser

public void configureWorkloadTraverser(WorkerUnitModelType type)
                                throws TaskTideEngineCheckedException

Configure TaskTideWorkloadTraverser for ItemTask/WorkItem. This should go through the UnitProvider builder

Parameters:

type -

Throws:

TaskTideEngineCheckedException

configureEngineExecutor

public void configureEngineExecutor(WorkerUnitModelType type)
                             throws TaskTideEngineCheckedException

Configure TaskTideExecutor for ItemTask/WorkItem.

Parameters:

type -

Throws:

TaskTideEngineCheckedException

configureProcessExecutor

public void configureProcessExecutor()
                              throws TaskTideEngineCheckedException

Configures ProcessExecutor

Throws:

TaskTideEngineCheckedException

getEngineObserverChain

public <T extends TaskTideModel<T>>
TaskTideEngineObserver<T> getEngineObserverChain(WorkerUnitModelType type)
                                          throws TaskTideEngineUncheckedException

Fetch required TaskTideEngineObserver

Type Parameters:

T - of TaskTideModel

Parameters:

type -

Returns:

TaskTideEngineObserver

Throws:

TaskTideEngineUncheckedException

getEngineWorkloadTraverser

public <T extends TaskTideModel<T>>
TaskTideWorkloadTraverser<T> getEngineWorkloadTraverser(WorkerUnitModelType type)
                                                 throws TaskTideEngineUncheckedException

Fetch required TaskTideWorkloadTraverser

Type Parameters:

T - of TaskTideModel

Parameters:

type -

Returns:

TaskTideWorkloadTraverser

Throws:

TaskTideEngineUncheckedException

getProcessExecutor

public ProcessExecutor getProcessExecutor()
                                   throws TaskTideEngineUncheckedException

Fetch configured ProcessExecutor

Returns:

ProcessExecutor

Throws:

TaskTideEngineUncheckedException

getEngineExecutor

public <T extends TaskTideModel<T>>
TaskTideExecutor<T> getEngineExecutor(WorkerUnitModelType type)
                               throws TaskTideEngineUncheckedException

Fetch required TaskTideExecutor

Type Parameters:

T - of TaskTideModel

Parameters:

type -

Returns:

TaskTideExecutor

Throws:

TaskTideEngineUncheckedException

getJobEnvId

public String getJobEnvId()

Fetch job environment Id through TaskTideManagerUtility

Returns:

String

getThreadPool

public ExecutorService getThreadPool(WorkerUnitModelType type)
                              throws TaskTideEngineUncheckedException

Fetch ExecutorService thread pool for asyncronous processing

Parameters:

type -

Returns:

ExecutorService

Throws:

TaskTideEngineUncheckedException

getStreamPath

public Path getStreamPath()

Get configured Path for ProcessExecutor streams, defaulting to current directory under 'tasktide-process-executor-streams'

Returns:

Path

configureStreamPath

public void configureStreamPath(String pathString)
                         throws TaskTideEngineCheckedException

Throws:

TaskTideEngineCheckedException

reset

public static void reset()

Reset the engine worker unit container for testing