Skip to content

Commit

Permalink
Add syncWorker flag
Browse files Browse the repository at this point in the history
  • Loading branch information
NV4RE committed Sep 2, 2020
1 parent eb487fd commit 973be1d
Show file tree
Hide file tree
Showing 68 changed files with 453 additions and 382 deletions.
14 changes: 7 additions & 7 deletions docs/classes/_taskdefinition_.taskdefinition.md
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@

\+ **new TaskDefinition**(`taskDefinition`: [ITaskDefinition](../interfaces/_taskdefinition_.itaskdefinition.md)): *[TaskDefinition](_taskdefinition_.taskdefinition.md)*

*Defined in [src/taskDefinition.ts:81](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/taskDefinition.ts#L81)*
*Defined in [src/taskDefinition.ts:90](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/taskDefinition.ts#L90)*

**Parameters:**

Expand All @@ -49,7 +49,7 @@ Name | Type |

*Implementation of [ITaskDefinition](../interfaces/_taskdefinition_.itaskdefinition.md).[ackTimeout](../interfaces/_taskdefinition_.itaskdefinition.md#optional-acktimeout)*

*Defined in [src/taskDefinition.ts:78](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/taskDefinition.ts#L78)*
*Defined in [src/taskDefinition.ts:87](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/taskDefinition.ts#L87)*

___

Expand All @@ -59,7 +59,7 @@ ___

*Implementation of [ITaskDefinition](../interfaces/_taskdefinition_.itaskdefinition.md).[description](../interfaces/_taskdefinition_.itaskdefinition.md#optional-description)*

*Defined in [src/taskDefinition.ts:77](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/taskDefinition.ts#L77)*
*Defined in [src/taskDefinition.ts:86](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/taskDefinition.ts#L86)*

___

Expand All @@ -69,7 +69,7 @@ ___

*Implementation of [ITaskDefinition](../interfaces/_taskdefinition_.itaskdefinition.md).[document](../interfaces/_taskdefinition_.itaskdefinition.md#optional-document)*

*Defined in [src/taskDefinition.ts:81](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/taskDefinition.ts#L81)*
*Defined in [src/taskDefinition.ts:90](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/taskDefinition.ts#L90)*

___

Expand All @@ -79,7 +79,7 @@ ___

*Implementation of [ITaskDefinition](../interfaces/_taskdefinition_.itaskdefinition.md).[name](../interfaces/_taskdefinition_.itaskdefinition.md#name)*

*Defined in [src/taskDefinition.ts:76](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/taskDefinition.ts#L76)*
*Defined in [src/taskDefinition.ts:85](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/taskDefinition.ts#L85)*

___

Expand All @@ -89,7 +89,7 @@ ___

*Implementation of [ITaskDefinition](../interfaces/_taskdefinition_.itaskdefinition.md).[retry](../interfaces/_taskdefinition_.itaskdefinition.md#optional-retry)*

*Defined in [src/taskDefinition.ts:80](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/taskDefinition.ts#L80)*
*Defined in [src/taskDefinition.ts:89](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/taskDefinition.ts#L89)*

___

Expand All @@ -99,4 +99,4 @@ ___

*Implementation of [ITaskDefinition](../interfaces/_taskdefinition_.itaskdefinition.md).[timeout](../interfaces/_taskdefinition_.itaskdefinition.md#optional-timeout)*

*Defined in [src/taskDefinition.ts:79](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/taskDefinition.ts#L79)*
*Defined in [src/taskDefinition.ts:88](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/taskDefinition.ts#L88)*
18 changes: 9 additions & 9 deletions docs/classes/_workflowdefinition_.workflowdefinition.md
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@

\+ **new WorkflowDefinition**(`workflowDefinition`: [IWorkflowDefinition](../interfaces/_workflowdefinition_.iworkflowdefinition.md)): *[WorkflowDefinition](_workflowdefinition_.workflowdefinition.md)*

*Defined in [src/workflowDefinition.ts:342](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/workflowDefinition.ts#L342)*
*Defined in [src/workflowDefinition.ts:352](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/workflowDefinition.ts#L352)*

**Parameters:**

Expand All @@ -51,7 +51,7 @@ Name | Type |

*Implementation of [IWorkflowDefinition](../interfaces/_workflowdefinition_.iworkflowdefinition.md).[description](../interfaces/_workflowdefinition_.iworkflowdefinition.md#optional-description)*

*Defined in [src/workflowDefinition.ts:337](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/workflowDefinition.ts#L337)*
*Defined in [src/workflowDefinition.ts:347](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/workflowDefinition.ts#L347)*

___

Expand All @@ -61,7 +61,7 @@ ___

*Implementation of [IWorkflowDefinition](../interfaces/_workflowdefinition_.iworkflowdefinition.md).[failureStrategy](../interfaces/_workflowdefinition_.iworkflowdefinition.md#optional-failurestrategy)*

*Defined in [src/workflowDefinition.ts:339](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/workflowDefinition.ts#L339)*
*Defined in [src/workflowDefinition.ts:349](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/workflowDefinition.ts#L349)*

___

Expand All @@ -71,7 +71,7 @@ ___

*Implementation of [IWorkflowDefinition](../interfaces/_workflowdefinition_.iworkflowdefinition.md).[name](../interfaces/_workflowdefinition_.iworkflowdefinition.md#name)*

*Defined in [src/workflowDefinition.ts:335](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/workflowDefinition.ts#L335)*
*Defined in [src/workflowDefinition.ts:345](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/workflowDefinition.ts#L345)*

___

Expand All @@ -81,7 +81,7 @@ ___

*Implementation of [IWorkflowDefinition](../interfaces/_workflowdefinition_.iworkflowdefinition.md).[outputParameters](../interfaces/_workflowdefinition_.iworkflowdefinition.md#optional-outputparameters)*

*Defined in [src/workflowDefinition.ts:342](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/workflowDefinition.ts#L342)*
*Defined in [src/workflowDefinition.ts:352](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/workflowDefinition.ts#L352)*

___

Expand All @@ -91,7 +91,7 @@ ___

*Implementation of [IWorkflowDefinition](../interfaces/_workflowdefinition_.iworkflowdefinition.md).[recoveryWorkflow](../interfaces/_workflowdefinition_.iworkflowdefinition.md#optional-recoveryworkflow)*

*Defined in [src/workflowDefinition.ts:341](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/workflowDefinition.ts#L341)*
*Defined in [src/workflowDefinition.ts:351](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/workflowDefinition.ts#L351)*

___

Expand All @@ -101,7 +101,7 @@ ___

*Implementation of [IWorkflowDefinition](../interfaces/_workflowdefinition_.iworkflowdefinition.md).[retry](../interfaces/_workflowdefinition_.iworkflowdefinition.md#optional-retry)*

*Defined in [src/workflowDefinition.ts:340](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/workflowDefinition.ts#L340)*
*Defined in [src/workflowDefinition.ts:350](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/workflowDefinition.ts#L350)*

___

Expand All @@ -111,7 +111,7 @@ ___

*Implementation of [IWorkflowDefinition](../interfaces/_workflowdefinition_.iworkflowdefinition.md).[rev](../interfaces/_workflowdefinition_.iworkflowdefinition.md#rev)*

*Defined in [src/workflowDefinition.ts:336](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/workflowDefinition.ts#L336)*
*Defined in [src/workflowDefinition.ts:346](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/workflowDefinition.ts#L346)*

___

Expand All @@ -121,4 +121,4 @@ ___

*Implementation of [IWorkflowDefinition](../interfaces/_workflowdefinition_.iworkflowdefinition.md).[tasks](../interfaces/_workflowdefinition_.iworkflowdefinition.md#tasks)*

*Defined in [src/workflowDefinition.ts:338](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/workflowDefinition.ts#L338)*
*Defined in [src/workflowDefinition.ts:348](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/workflowDefinition.ts#L348)*
10 changes: 5 additions & 5 deletions docs/enums/_command_.commandtypes.md
Original file line number Diff line number Diff line change
Expand Up @@ -18,36 +18,36 @@

**CancelTransaction**: = "CANCEL_TRANSACTION"

*Defined in [src/command.ts:6](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/command.ts#L6)*
*Defined in [src/command.ts:6](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/command.ts#L6)*

___

### PauseTransaction

**PauseTransaction**: = "PAUSE_TRANSACTION"

*Defined in [src/command.ts:7](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/command.ts#L7)*
*Defined in [src/command.ts:7](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/command.ts#L7)*

___

### ReloadTask

**ReloadTask**: = "RELOAD_TASK"

*Defined in [src/command.ts:9](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/command.ts#L9)*
*Defined in [src/command.ts:9](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/command.ts#L9)*

___

### ResumeTransaction

**ResumeTransaction**: = "RESUME_TRANSACTION"

*Defined in [src/command.ts:8](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/command.ts#L8)*
*Defined in [src/command.ts:8](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/command.ts#L8)*

___

### StartTransaction

**StartTransaction**: = "START_TRANSACTION"

*Defined in [src/command.ts:5](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/command.ts#L5)*
*Defined in [src/command.ts:5](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/command.ts#L5)*
10 changes: 5 additions & 5 deletions docs/enums/_kafka_.topicsuffix.md
Original file line number Diff line number Diff line change
Expand Up @@ -18,36 +18,36 @@

**command**: = "command"

*Defined in [src/kafka.ts:7](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/kafka.ts#L7)*
*Defined in [src/kafka.ts:7](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/kafka.ts#L7)*

___

### event

**event**: = "event"

*Defined in [src/kafka.ts:4](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/kafka.ts#L4)*
*Defined in [src/kafka.ts:4](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/kafka.ts#L4)*

___

### store

**store**: = "store"

*Defined in [src/kafka.ts:5](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/kafka.ts#L5)*
*Defined in [src/kafka.ts:5](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/kafka.ts#L5)*

___

### task

**task**: = "task"

*Defined in [src/kafka.ts:6](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/kafka.ts#L6)*
*Defined in [src/kafka.ts:6](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/kafka.ts#L6)*

___

### timer

**timer**: = "timer"

*Defined in [src/kafka.ts:8](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/kafka.ts#L8)*
*Defined in [src/kafka.ts:8](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/kafka.ts#L8)*
12 changes: 6 additions & 6 deletions docs/enums/_state_.taskstates.md
Original file line number Diff line number Diff line change
Expand Up @@ -19,44 +19,44 @@

**AckTimeOut**: = "ACK_TIMEOUT"

*Defined in [src/state.ts:163](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/state.ts#L163)*
*Defined in [src/state.ts:163](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/state.ts#L163)*

___

### Completed

**Completed**: = "COMPLETED"

*Defined in [src/state.ts:160](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/state.ts#L160)*
*Defined in [src/state.ts:160](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/state.ts#L160)*

___

### Failed

**Failed**: = "FAILED"

*Defined in [src/state.ts:161](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/state.ts#L161)*
*Defined in [src/state.ts:161](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/state.ts#L161)*

___

### Inprogress

**Inprogress**: = "INPROGRESS"

*Defined in [src/state.ts:159](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/state.ts#L159)*
*Defined in [src/state.ts:159](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/state.ts#L159)*

___

### Scheduled

**Scheduled**: = "SCHEDULED"

*Defined in [src/state.ts:158](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/state.ts#L158)*
*Defined in [src/state.ts:158](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/state.ts#L158)*

___

### Timeout

**Timeout**: = "TIMEOUT"

*Defined in [src/state.ts:162](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/state.ts#L162)*
*Defined in [src/state.ts:162](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/state.ts#L162)*
12 changes: 6 additions & 6 deletions docs/enums/_state_.transactionstates.md
Original file line number Diff line number Diff line change
Expand Up @@ -19,44 +19,44 @@

**Cancelled**: = "CANCELLED"

*Defined in [src/state.ts:10](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/state.ts#L10)*
*Defined in [src/state.ts:10](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/state.ts#L10)*

___

### Compensated

**Compensated**: = "COMPENSATED"

*Defined in [src/state.ts:11](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/state.ts#L11)*
*Defined in [src/state.ts:11](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/state.ts#L11)*

___

### Completed

**Completed**: = "COMPLETED"

*Defined in [src/state.ts:6](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/state.ts#L6)*
*Defined in [src/state.ts:6](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/state.ts#L6)*

___

### Failed

**Failed**: = "FAILED"

*Defined in [src/state.ts:7](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/state.ts#L7)*
*Defined in [src/state.ts:7](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/state.ts#L7)*

___

### Paused

**Paused**: = "PAUSED"

*Defined in [src/state.ts:9](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/state.ts#L9)*
*Defined in [src/state.ts:9](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/state.ts#L9)*

___

### Running

**Running**: = "RUNNING"

*Defined in [src/state.ts:8](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/state.ts#L8)*
*Defined in [src/state.ts:8](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/state.ts#L8)*
10 changes: 5 additions & 5 deletions docs/enums/_state_.workflowfailurestrategies.md
Original file line number Diff line number Diff line change
Expand Up @@ -18,36 +18,36 @@

**Compensate**: = "COMPENSATE"

*Defined in [src/state.ts:120](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/state.ts#L120)*
*Defined in [src/state.ts:120](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/state.ts#L120)*

___

### CompensateThenRetry

**CompensateThenRetry**: = "COMPENSATE_THEN_RETRY"

*Defined in [src/state.ts:121](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/state.ts#L121)*
*Defined in [src/state.ts:121](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/state.ts#L121)*

___

### Failed

**Failed**: = "FAILED"

*Defined in [src/state.ts:117](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/state.ts#L117)*
*Defined in [src/state.ts:117](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/state.ts#L117)*

___

### RecoveryWorkflow

**RecoveryWorkflow**: = "RECOVERY_WORKFLOW"

*Defined in [src/state.ts:118](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/state.ts#L118)*
*Defined in [src/state.ts:118](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/state.ts#L118)*

___

### Retry

**Retry**: = "RETRY"

*Defined in [src/state.ts:119](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/state.ts#L119)*
*Defined in [src/state.ts:119](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/state.ts#L119)*
Loading

0 comments on commit 973be1d

Please sign in to comment.