Class BaseWorkflowClient

Hierarchy

BaseWorkflowClient

Implements

WorkflowClient

Index

Constructors

constructor

Properties

Methods

Constructors

constructor

new BaseWorkflowClient(awsAdapter: AWSClientProvider, logger: Logger): BaseWorkflowClient

- Defined in aws/workflow-client.ts:34
Parameters
- awsAdapter: AWSClientProvider
- logger: Logger
Returns BaseWorkflowClient

Properties

Private awsAdapter

awsAdapter: AWSClientProvider

Private logger

logger: Logger

Private swfClient

swfClient: SWF

Methods

fromSwfFunction

fromSwfFunction<T>(fnc: function, params: any): Observable<T>

- Defined in aws/workflow-client.ts:73
Type parameters
- T
Parameters
- fnc: function
  - - <T>(params: any, cb: function): any
    - Type parameters
      - T
      Parameters
      - params: any
      - cb: function
        
        (error: any, data: T): void
        
        Parameters
        
        error: any
        
        data: T
        
        Returns void
      Returns any
- params: any
Returns Observable<T>

pollForActivityTask

pollForActivityTask(params: ActivityPollParameters): Observable<ActivityTask>

Implementation of WorkflowClient.pollForActivityTask
- Defined in aws/workflow-client.ts:40
Parameters
- params: ActivityPollParameters
Returns Observable<ActivityTask>

pollForDecisionTask

pollForDecisionTask(params: DecisionPollParameters): Observable<DecisionTask>

Implementation of WorkflowClient.pollForDecisionTask
- Defined in aws/workflow-client.ts:44
Parameters
- params: DecisionPollParameters
Returns Observable<DecisionTask>

registerActivityType

registerActivityType(params: RegisterActivityTypeInput): Observable<RegisterActivityTypeInput>

Implementation of WorkflowClient.registerActivityType
- Defined in aws/workflow-client.ts:56
Parameters
- params: RegisterActivityTypeInput
Returns Observable<RegisterActivityTypeInput>

registerWorkflowType

registerWorkflowType(params: RegisterWorkflowTypeInput): Observable<RegisterWorkflowTypeInput>

Implementation of WorkflowClient.registerWorkflowType
- Defined in aws/workflow-client.ts:52
Parameters
- params: RegisterWorkflowTypeInput
Returns Observable<RegisterWorkflowTypeInput>

respondActivityTaskCompleted

respondActivityTaskCompleted(params: RespondActivityTaskCompletedInput): Observable<__type>

Implementation of WorkflowClient.respondActivityTaskCompleted
- Defined in aws/workflow-client.ts:64
Parameters
- params: RespondActivityTaskCompletedInput
Returns Observable<__type>

respondActivityTaskFailed

respondActivityTaskFailed(params: RespondActivityTaskFailedInput): Observable<__type>

Implementation of WorkflowClient.respondActivityTaskFailed
- Defined in aws/workflow-client.ts:68
Parameters
- params: RespondActivityTaskFailedInput
Returns Observable<__type>

respondDecisionTaskCompleted

respondDecisionTaskCompleted(params: RespondDecisionTaskCompletedInput): Observable<__type>

Implementation of WorkflowClient.respondDecisionTaskCompleted
- Defined in aws/workflow-client.ts:60
Parameters
- params: RespondDecisionTaskCompletedInput
Returns Observable<__type>

startWorkflow

startWorkflow(params: WorkflowStartParameters): Observable<Run>

Implementation of WorkflowClient.startWorkflow
- Defined in aws/workflow-client.ts:48
Parameters
- params: WorkflowStartParameters
Returns Observable<Run>

Generated using TypeDoc