Skip to content

Commit f3ec67f

Browse files
authored
Merge pull request #12 from devit-tel/feature/add-sync-worker-field
Feature/add sync worker field
2 parents 6de5a0c + 973be1d commit f3ec67f

File tree

70 files changed

+473
-383
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

70 files changed

+473
-383
lines changed

docs/classes/_taskdefinition_.taskdefinition.md

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@
3131

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

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

3636
**Parameters:**
3737

@@ -49,7 +49,7 @@ Name | Type |
4949

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

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

5454
___
5555

@@ -59,7 +59,7 @@ ___
5959

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

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

6464
___
6565

@@ -69,7 +69,7 @@ ___
6969

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

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

7474
___
7575

@@ -79,7 +79,7 @@ ___
7979

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

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

8484
___
8585

@@ -89,7 +89,7 @@ ___
8989

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

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

9494
___
9595

@@ -99,4 +99,4 @@ ___
9999

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

102-
*Defined in [src/taskDefinition.ts:79](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/taskDefinition.ts#L79)*
102+
*Defined in [src/taskDefinition.ts:88](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/taskDefinition.ts#L88)*

docs/classes/_workflowdefinition_.workflowdefinition.md

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@
3333

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

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

3838
**Parameters:**
3939

@@ -51,7 +51,7 @@ Name | Type |
5151

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

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

5656
___
5757

@@ -61,7 +61,7 @@ ___
6161

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

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

6666
___
6767

@@ -71,7 +71,7 @@ ___
7171

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

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

7676
___
7777

@@ -81,7 +81,7 @@ ___
8181

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

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

8686
___
8787

@@ -91,7 +91,7 @@ ___
9191

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

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

9696
___
9797

@@ -101,7 +101,7 @@ ___
101101

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

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

106106
___
107107

@@ -111,7 +111,7 @@ ___
111111

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

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

116116
___
117117

@@ -121,4 +121,4 @@ ___
121121

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

124-
*Defined in [src/workflowDefinition.ts:338](https://github.com/devit-tel/melonade-declaration/blob/26b2f11/src/workflowDefinition.ts#L338)*
124+
*Defined in [src/workflowDefinition.ts:348](https://github.com/devit-tel/melonade-declaration/blob/eb487fd/src/workflowDefinition.ts#L348)*

docs/enums/_command_.commandtypes.md

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -18,36 +18,36 @@
1818

1919
**CancelTransaction**: = "CANCEL_TRANSACTION"
2020

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

2323
___
2424

2525
### PauseTransaction
2626

2727
**PauseTransaction**: = "PAUSE_TRANSACTION"
2828

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

3131
___
3232

3333
### ReloadTask
3434

3535
**ReloadTask**: = "RELOAD_TASK"
3636

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

3939
___
4040

4141
### ResumeTransaction
4242

4343
**ResumeTransaction**: = "RESUME_TRANSACTION"
4444

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

4747
___
4848

4949
### StartTransaction
5050

5151
**StartTransaction**: = "START_TRANSACTION"
5252

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

docs/enums/_kafka_.topicsuffix.md

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -18,36 +18,36 @@
1818

1919
**command**: = "command"
2020

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

2323
___
2424

2525
### event
2626

2727
**event**: = "event"
2828

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

3131
___
3232

3333
### store
3434

3535
**store**: = "store"
3636

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

3939
___
4040

4141
### task
4242

4343
**task**: = "task"
4444

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

4747
___
4848

4949
### timer
5050

5151
**timer**: = "timer"
5252

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

docs/enums/_state_.taskstates.md

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -19,44 +19,44 @@
1919

2020
**AckTimeOut**: = "ACK_TIMEOUT"
2121

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

2424
___
2525

2626
### Completed
2727

2828
**Completed**: = "COMPLETED"
2929

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

3232
___
3333

3434
### Failed
3535

3636
**Failed**: = "FAILED"
3737

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

4040
___
4141

4242
### Inprogress
4343

4444
**Inprogress**: = "INPROGRESS"
4545

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

4848
___
4949

5050
### Scheduled
5151

5252
**Scheduled**: = "SCHEDULED"
5353

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

5656
___
5757

5858
### Timeout
5959

6060
**Timeout**: = "TIMEOUT"
6161

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

docs/enums/_state_.transactionstates.md

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -19,44 +19,44 @@
1919

2020
**Cancelled**: = "CANCELLED"
2121

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

2424
___
2525

2626
### Compensated
2727

2828
**Compensated**: = "COMPENSATED"
2929

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

3232
___
3333

3434
### Completed
3535

3636
**Completed**: = "COMPLETED"
3737

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

4040
___
4141

4242
### Failed
4343

4444
**Failed**: = "FAILED"
4545

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

4848
___
4949

5050
### Paused
5151

5252
**Paused**: = "PAUSED"
5353

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

5656
___
5757

5858
### Running
5959

6060
**Running**: = "RUNNING"
6161

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

docs/enums/_state_.workflowfailurestrategies.md

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -18,36 +18,36 @@
1818

1919
**Compensate**: = "COMPENSATE"
2020

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

2323
___
2424

2525
### CompensateThenRetry
2626

2727
**CompensateThenRetry**: = "COMPENSATE_THEN_RETRY"
2828

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

3131
___
3232

3333
### Failed
3434

3535
**Failed**: = "FAILED"
3636

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

3939
___
4040

4141
### RecoveryWorkflow
4242

4343
**RecoveryWorkflow**: = "RECOVERY_WORKFLOW"
4444

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

4747
___
4848

4949
### Retry
5050

5151
**Retry**: = "RETRY"
5252

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

0 commit comments

Comments
 (0)