Class WorkflowAcquisitionPolicy

java.lang.Object

org.tasktide.engine.policies.AbstractAcquisitionPolicy

org.tasktide.engine.policies.WorkflowAcquisitionPolicy

All Implemented Interfaces:

TaskTideWorkloadAcquisitionPolicy

public class WorkflowAcquisitionPolicy
extends AbstractAcquisitionPolicy

AbstractAcquisitionPolicy for user-defined workflow as an order provided list of Step names. With configurable WorkflowAcquisitionStrategy for the consummation of each step, as SequentialWorkflowStrategy or RoundRobinWorkflowStrategy.

Realistically sequential processing would be for batch mode, and round robin for service. However, the design pattern here caters for development.

Field Summary

Fields

Modifier and Type	Field	Description
protected WorkflowAcquisitionStrategy	strategy

Fields inherited from class AbstractAcquisitionPolicy

counter, id, iterationLimit, policyType, poolSize, windowSize

Method Summary

Modifier and Type	Method	Description
TaskTideWorkloadAcquisitionPolicy	clonePolicy()	Clone the WorkflowAcquisitionPolicy
List<WorkItem>	fetchWorkload()	Fetch WorkItem workload through WorkflowAcquisitionStrategy interface
TaskTideWorkloadAcquisitionPolicy	getPolicyForTarget(String step)	Fetch policy for active target
List<String>	getQueueTargets()	Get elements still in the queue
List<String>	getStepList()	Fetch clone of step list
WorkflowStrategyMode	getStrategyMode()	Get WorkflowStrategyMode
WorkflowStrategyType	getStrategyType()	Get WorkflowStrategyType
String	getTarget()	Get active TaskTideWorkloadAcquisitionPolicy from WorkflowAcquisitionStrategy
boolean	hasNext()	Determines whether available task in active policy
void	reconfigureQueue()	Reset the WorkflowAcquisitionStrategy TaskTideWorkloadAcquisitionPolicy policy queue
boolean	workflowMode()	Returns true

Methods inherited from class AbstractAcquisitionPolicy

getAnno, getAnnoKey, getAnnoVal, getId, getIterationLimit, getPolicyMode, getPoolSize, getState, getWindowSize, isCustomAnnotated, isStringAnnotated, isTargeted, setAnno, setAnnoKeyValue, setIterationLimit, setPoolSize, setState, setWindowSize, toJsonDoc, toJsonString

Methods inherited from class Object

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

Field Details

strategy

protected WorkflowAcquisitionStrategy strategy

Method Details

fetchWorkload

public List<WorkItem> fetchWorkload()

Fetch WorkItem workload through WorkflowAcquisitionStrategy interface

Returns:

List-WorkItem

hasNext

public boolean hasNext()

Determines whether available task in active policy

Returns:

boolean

getPolicyForTarget

public TaskTideWorkloadAcquisitionPolicy getPolicyForTarget(String step)

Fetch policy for active target

Parameters:

step -

Returns:

TaskTideWorkloadAcquisitionPolicy-WorkItem

getStepList

public List<String> getStepList()

Fetch clone of step list

Returns:

List-String

getTarget

public String getTarget()

Get active TaskTideWorkloadAcquisitionPolicy from WorkflowAcquisitionStrategy

Specified by:

getTarget in interface TaskTideWorkloadAcquisitionPolicy

Overrides:

getTarget in class AbstractAcquisitionPolicy

Returns:

String

clonePolicy

public TaskTideWorkloadAcquisitionPolicy clonePolicy()

Clone the WorkflowAcquisitionPolicy

Returns:

WorkflowAcquisitionPolicy

workflowMode

public boolean workflowMode()

Returns true

Returns:

boolean

getStrategyType

public WorkflowStrategyType getStrategyType()

Get WorkflowStrategyType

Returns:

WorkflowStrategyType

getStrategyMode

public WorkflowStrategyMode getStrategyMode()

Get WorkflowStrategyMode

Returns:

WorkflowStrategyMode

reconfigureQueue

public void reconfigureQueue()

Reset the WorkflowAcquisitionStrategy TaskTideWorkloadAcquisitionPolicy policy queue

getQueueTargets

public List<String> getQueueTargets()

Get elements still in the queue

Returns:

List-String