Class AbstractWorkflowStrategy

java.lang.Object

org.tasktide.engine.policies.workflow.AbstractWorkflowStrategy

All Implemented Interfaces:

WorkflowAcquisitionStrategy

Direct Known Subclasses:

RoundRobinWorkflowStrategy, SequentialWorkflowStrategy

public abstract class AbstractWorkflowStrategy
extends Object
implements WorkflowAcquisitionStrategy

AbstractWorkflowStrategy to hold shared operational logic of concrete WorkflowStrategyType instances. Enforcing a queue ordering based on the provided TaskTideWorkloadAcquisitionPolicy

Field Summary

Fields

Modifier and Type	Field	Description
protected TaskTideWorkloadAcquisitionPolicy	activePolicy
protected int	counter
protected boolean	hasRun
protected final String	id
protected int	limit
protected WorkflowStrategyMode	mode
protected final List<TaskTideWorkloadAcquisitionPolicy>	policies
protected Deque<TaskTideWorkloadAcquisitionPolicy>	workflow

Method Summary

Modifier and Type	Method	Description
boolean	evaluateIterationCounter()	Handles iteration counter if configured
TaskTideWorkloadAcquisitionPolicy	getActive()	Get active TaskTideWorkloadAcquisitionPolicy
boolean	getHasRun()	Get whether strategy has run
String	getId()	Get Id
int	getIterationLimit()	Get iteration limit
List<String>	getQueueTargets()	Get target names from elements still in queue
WorkflowStrategyMode	getStrategyMode()	Get WorkflowStrategyMode
List<String>	getTargetNames()	Get target names as a list
boolean	hasNext()	Checks whether there active tasks in workflow
void	resetPolicyQueue()	Reset queue queue
void	setHasRun(boolean val)	Set has run for cloning
void	setIterationLimit(int limit)	Set iteration limit
void	setStrategyMode(WorkflowStrategyMode mode)	Set WorkflowStrategyMode

Methods inherited from class Object

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

Methods inherited from interface WorkflowAcquisitionStrategy

configureDefaultStrategyMode, evaluateWorkload, fetchWorkload

Field Details

id

protected final String id

policies

protected final List<TaskTideWorkloadAcquisitionPolicy> policies

workflow

protected Deque<TaskTideWorkloadAcquisitionPolicy> workflow

activePolicy

protected TaskTideWorkloadAcquisitionPolicy activePolicy

mode

protected WorkflowStrategyMode mode

limit

protected int limit

counter

protected int counter

hasRun

protected boolean hasRun

Method Details

hasNext

public boolean hasNext()

Checks whether there active tasks in workflow

Specified by:

hasNext in interface WorkflowAcquisitionStrategy

Returns:

boolean

setStrategyMode

public void setStrategyMode(WorkflowStrategyMode mode)

Set WorkflowStrategyMode

Specified by:

setStrategyMode in interface WorkflowAcquisitionStrategy

Parameters:

mode -

getStrategyMode

public WorkflowStrategyMode getStrategyMode()

Get WorkflowStrategyMode

Specified by:

getStrategyMode in interface WorkflowAcquisitionStrategy

Returns:

WorkflowStrategyMode

getActive

public TaskTideWorkloadAcquisitionPolicy getActive()

Get active TaskTideWorkloadAcquisitionPolicy

Specified by:

getActive in interface WorkflowAcquisitionStrategy

Returns:

TaskTideWorkloadAcquisitionPolicy

setIterationLimit

public void setIterationLimit(int limit)

Set iteration limit

Specified by:

setIterationLimit in interface WorkflowAcquisitionStrategy

Parameters:

limit -

getIterationLimit

public int getIterationLimit()

Get iteration limit

Specified by:

getIterationLimit in interface WorkflowAcquisitionStrategy

Returns:

int

getTargetNames

public List<String> getTargetNames()

Get target names as a list

Specified by:

getTargetNames in interface WorkflowAcquisitionStrategy

Returns:

String

getId

public String getId()

Get Id

Specified by:

getId in interface WorkflowAcquisitionStrategy

Returns:

String

evaluateIterationCounter

public boolean evaluateIterationCounter()

Handles iteration counter if configured

Specified by:

evaluateIterationCounter in interface WorkflowAcquisitionStrategy

Returns:

boolean

resetPolicyQueue

public void resetPolicyQueue()

Reset queue queue

Specified by:

resetPolicyQueue in interface WorkflowAcquisitionStrategy

getQueueTargets

public List<String> getQueueTargets()

Get target names from elements still in queue

Specified by:

getQueueTargets in interface WorkflowAcquisitionStrategy

Returns:

List-String

setHasRun

public void setHasRun(boolean val)

Set has run for cloning

Specified by:

setHasRun in interface WorkflowAcquisitionStrategy

Parameters:

val -

getHasRun

public boolean getHasRun()

Get whether strategy has run

Specified by:

getHasRun in interface WorkflowAcquisitionStrategy

Returns:

boolean