Interface WorkflowAcquisitionStrategy

All Known Implementing Classes:
AbstractWorkflowStrategy, RoundRobinWorkflowStrategy, SequentialWorkflowStrategy
public interface WorkflowAcquisitionStrategy
Defines specifications for different ways to fetch workload from a collection of steps

  • Method Details

    • evaluateWorkload

      List<WorkItem> evaluateWorkload(List<WorkItem> workload)
      Evaluate retrieved workload
      Parameters:
      workload -
      Returns:
      List=WorkItem

    • fetchWorkload

      List<WorkItem> fetchWorkload()
      Fetches workload from step in provided collection
      Returns:
      List-TaskTideWorkloadAcquisitionPolicy

    • hasNext

      boolean hasNext()
      Checks whether there are any available tasks left in the active step, or throws TaskTideEngineUncheckedException if not yet configured
      Returns:
      boolean

    • setStrategyMode

      void setStrategyMode(WorkflowStrategyMode mode)
      Sets WorkflowStrategyMode currently SCANNER, or EXAHUST of strategy
      Parameters:
      mode -

    • getStrategyMode

      WorkflowStrategyMode getStrategyMode()
      Provides WorkflowStrategyMode of strategy
      Returns:
      WorkflowStrategyMode

    • getActive

      TaskTideWorkloadAcquisitionPolicy getActive()
      Returns active policy
      Returns:
      TaskTideWorkloadAcquisitionPolicy

    • setIterationLimit

      void setIterationLimit(int limit)
      Set an iteration on algorithm
      Parameters:
      limit -

    • getIterationLimit

      int getIterationLimit()
      Get iteration limit
      Returns:
      int

    • getTargetNames

      List<String> getTargetNames()
      Get target names as a list
      Returns:
      String

    • getId

      String getId()
      Get Id
      Returns:
      String

    • configureDefaultStrategyMode

      void configureDefaultStrategyMode()
      Configure default WorkflowStrategyMode

    • evaluateIterationCounter

      boolean evaluateIterationCounter()
      Evaluate iteration counter
      Returns:
      boolean

    • resetPolicyQueue

      void resetPolicyQueue()
      Reset policy queue

    • getQueueTargets

      List<String> getQueueTargets()
      Fetch target names from workload queue
      Returns:
      List-String

    • getHasRun

      boolean getHasRun()
      Get whether strategy has run
      Returns:
      boolean

    • setHasRun

      void setHasRun(boolean val)
      Set whether strategy has run
      Parameters:
      val -