diff options
| author | Austin Schaffer <austin.schaffer@ryansg.com> | 2019-11-21 15:59:17 -0500 |
|---|---|---|
| committer | Austin Schaffer <austin.schaffer@ryansg.com> | 2019-11-22 16:37:57 -0500 |
| commit | faa7e15760d1136ef44b15a914c5dd582f86a903 (patch) | |
| tree | 789e48bf79e12accb31712791de7c65a87a5eb86 /test | |
| parent | 9b5cd4e89f8d8778994a01eca641d4b78296c4d9 (diff) | |
| download | liza-faa7e15760d1136ef44b15a914c5dd582f86a903.tar.gz liza-faa7e15760d1136ef44b15a914c5dd582f86a903.tar.bz2 liza-faa7e15760d1136ef44b15a914c5dd582f86a903.zip | |
[DEV-5312] Add signal handling and prometheus monitoring
Diffstat (limited to 'test')
| -rw-r--r-- | test/system/DeltaProcessorTest.ts | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/test/system/DeltaProcessorTest.ts b/test/system/DeltaProcessorTest.ts index d32197e..bccd4a4 100644 --- a/test/system/DeltaProcessorTest.ts +++ b/test/system/DeltaProcessorTest.ts @@ -241,7 +241,7 @@ describe( 'system.DeltaProcessor', () => }, ], }, - lastPublishDelta: { + totalPublishDelta: { data: 0, }, }, @@ -274,7 +274,7 @@ describe( 'system.DeltaProcessor', () => }, ], }, - lastPublishDelta: { + totalPublishDelta: { data: 1, }, }, @@ -308,6 +308,8 @@ function createMockDeltaDao(): DeltaDao getUnprocessedDocuments() { return Promise.resolve( [] ); }, advanceDeltaIndex() { return Promise.resolve( null ); }, markDocumentAsProcessed() { return Promise.resolve( null ); }, + setErrorFlag() { return Promise.resolve( null ); }, + getErrorCount() { return Promise.resolve( 0 ); }, }; } |