Class BaseWorkflowWorker<T>

Type parameters

T

Hierarchy

BaseWorkflowWorker

Implements

WorkflowWorker<T>

Constructors

constructor

new BaseWorkflowWorker(workflowClient: WorkflowClient, appContainer: Container, contextCache: ContextCache, poller: TaskPollerObservable<DecisionTask>, domain: string, bindings: Binding[], logger: Logger): BaseWorkflowWorker

- Defined in core/workflow/worker/workflow-worker.ts:32
Parameters
- workflowClient: WorkflowClient
- appContainer: Container
- contextCache: ContextCache
- poller: TaskPollerObservable<DecisionTask>
- domain: string
- bindings: Binding[]
- logger: Logger
Returns BaseWorkflowWorker

Properties

Private appContainer

appContainer: Container

Private bindings

bindings: Binding[]

Private contextCache

contextCache: ContextCache

Private domain

domain: string

Private logger

logger: Logger

Private pollSubscription

pollSubscription: Subscription

Private poller

poller: TaskPollerObservable<DecisionTask>

Private wfStub

wfStub: LocalStub

Private workflowClient

workflowClient: WorkflowClient

Methods

createWorkflowStub

createWorkflowStub(): LocalStub

- Defined in core/workflow/worker/workflow-worker.ts:154
Returns LocalStub

Private processDecision

processDecision(context: DecisionRunContext, decisionTask: DecisionTask): Observable<__type>

- Defined in core/workflow/worker/workflow-worker.ts:87
Parameters
- context: DecisionRunContext
- decisionTask: DecisionTask
Returns Observable<__type>

register

register(): Observable<any>

Implementation of WorkflowWorker.register
- Defined in core/workflow/worker/workflow-worker.ts:158
Returns Observable<any>

Private registerWorkflow

registerWorkflow(definition: WorkflowDefinition): Observable<any>

- Defined in core/workflow/worker/workflow-worker.ts:75
Parameters
- definition: WorkflowDefinition
Returns Observable<any>

Private respondActivityDecisions

respondActivityDecisions(taskToken: string, context: DecisionRunContext): Observable<__type>

- Defined in core/workflow/worker/workflow-worker.ts:131
Parameters
- taskToken: string
- context: DecisionRunContext
Returns Observable<__type>

Private respondCompletedWorkflowDecision

respondCompletedWorkflowDecision(result: string, context: DecisionRunContext): Observable<Object | __type>

- Defined in core/workflow/worker/workflow-worker.ts:95
Parameters
- result: string
- context: DecisionRunContext
Returns Observable<Object | __type>

Private respondFailedWorkflowDecision

respondFailedWorkflowDecision(details?: string, reason: string, context: DecisionRunContext): Observable<Object | __type>

- Defined in core/workflow/worker/workflow-worker.ts:112
Parameters
- Default value details: string = "error"
- reason: string
- context: DecisionRunContext
Returns Observable<Object | __type>

startWorker

startWorker(): void

Implementation of WorkflowWorker.startWorker
- Defined in core/workflow/worker/workflow-worker.ts:165
Returns void

Private workflowDefinitionToRegisterWorkflowTypeInput

workflowDefinitionToRegisterWorkflowTypeInput(definition: WorkflowDefinition): RegisterWorkflowTypeInput

- Defined in core/workflow/worker/workflow-worker.ts:43
Parameters
- definition: WorkflowDefinition
Returns RegisterWorkflowTypeInput

Static Private createActivityScheduleDecisionFromStateMachine

createActivityScheduleDecisionFromStateMachine(sm: ActivityDecisionStateMachine): Decision

- Defined in core/workflow/worker/workflow-worker.ts:65
Parameters
- sm: ActivityDecisionStateMachine
Returns Decision

Static Private createCompletedInput

createCompletedInput(taskToken: string, decisions: DecisionList): RespondDecisionTaskCompletedInput

- Defined in core/workflow/worker/workflow-worker.ts:58
Parameters
- taskToken: string
- decisions: DecisionList
Returns RespondDecisionTaskCompletedInput

Generated using TypeDoc