co.cask.cdap.test.remote

Class RemoteWorkflowManager

java.lang.Object

co.cask.cdap.test.AbstractProgramManager<WorkflowManager>

co.cask.cdap.test.remote.RemoteWorkflowManager

All Implemented Interfaces:

ProgramManager<WorkflowManager>, WorkflowManager

public class RemoteWorkflowManager
extends AbstractProgramManager<WorkflowManager>
implements WorkflowManager

Remote implementation of WorkflowManager.

Field Summary

Fields inherited from class co.cask.cdap.test.AbstractProgramManager

programId

Constructor Summary

Constructors

Constructor and Description
RemoteWorkflowManager(WorkflowId programId, ClientConfig clientConfig, RESTClient restClient, RemoteApplicationManager applicationManager)

Method Summary

Methods

Modifier and Type	Method and Description
ScheduleManager	getSchedule(String schedName)
List<ScheduleSpecification>	getSchedules()
WorkflowTokenDetail	getToken(String runId, WorkflowToken.Scope scope, String key)
WorkflowTokenNodeDetail	getTokenAtNode(String runId, String nodeName, WorkflowToken.Scope scope, String key)
Map<String,WorkflowNodeStateDetail>	getWorkflowNodeStates(String workflowRunId)

Methods inherited from class co.cask.cdap.test.AbstractProgramManager

getHistory, getHistory, getRuntimeArgs, isRunning, setRuntimeArgs, start, start, stop, waitForFinish, waitForRun, waitForRuns, waitForStatus, waitForStatus, waitForStatus

Methods inherited from class java.lang.Object

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

Methods inherited from interface co.cask.cdap.test.ProgramManager

getHistory, getHistory, getRuntimeArgs, isRunning, setRuntimeArgs, start, start, stop, waitForFinish, waitForRun, waitForRuns, waitForStatus, waitForStatus

Constructor Detail

RemoteWorkflowManager

public RemoteWorkflowManager(WorkflowId programId,
                     ClientConfig clientConfig,
                     RESTClient restClient,
                     RemoteApplicationManager applicationManager)

Method Detail

getSchedules

public List<ScheduleSpecification> getSchedules()

Specified by:

getSchedules in interface WorkflowManager

getToken

public WorkflowTokenDetail getToken(String runId,
                           @Nullable
                           WorkflowToken.Scope scope,
                           @Nullable
                           String key)
                             throws NotFoundException

Specified by:

getToken in interface WorkflowManager

Throws:

NotFoundException

getTokenAtNode

public WorkflowTokenNodeDetail getTokenAtNode(String runId,
                                     String nodeName,
                                     @Nullable
                                     WorkflowToken.Scope scope,
                                     @Nullable
                                     String key)
                                       throws NotFoundException

Specified by:

getTokenAtNode in interface WorkflowManager

Throws:

NotFoundException

getWorkflowNodeStates

public Map<String,WorkflowNodeStateDetail> getWorkflowNodeStates(String workflowRunId)
                                                          throws NotFoundException

Specified by:

getWorkflowNodeStates in interface WorkflowManager

Throws:

NotFoundException

getSchedule

public ScheduleManager getSchedule(String schedName)

Specified by:

getSchedule in interface WorkflowManager