Commit 91ef5319 authored by Hamdi Allam's avatar Hamdi Allam

add elapsed time to log

parent 66af289c
...@@ -267,6 +267,9 @@ export class FaultDetector extends BaseServiceV2<Options, Metrics, State> { ...@@ -267,6 +267,9 @@ export class FaultDetector extends BaseServiceV2<Options, Metrics, State> {
this.logger.info('starting height', { this.logger.info('starting height', {
startBatchIndex: this.state.currentBatchIndex, startBatchIndex: this.state.currentBatchIndex,
}) })
// Set the initial metrics.
this.metrics.isCurrentlyMismatched.set(0)
} }
async routes(router: ExpressRouter): Promise<void> { async routes(router: ExpressRouter): Promise<void> {
...@@ -278,6 +281,8 @@ export class FaultDetector extends BaseServiceV2<Options, Metrics, State> { ...@@ -278,6 +281,8 @@ export class FaultDetector extends BaseServiceV2<Options, Metrics, State> {
} }
async main(): Promise<void> { async main(): Promise<void> {
const startMs = Date.now()
let latestBatchIndex: number let latestBatchIndex: number
try { try {
latestBatchIndex = (await this.state.oo.getTotalElements()).toNumber() latestBatchIndex = (await this.state.oo.getTotalElements()).toNumber()
...@@ -520,9 +525,12 @@ export class FaultDetector extends BaseServiceV2<Options, Metrics, State> { ...@@ -520,9 +525,12 @@ export class FaultDetector extends BaseServiceV2<Options, Metrics, State> {
} }
} }
const elapsedMs = Date.now() - startMs
// Mark the current batch index as checked // Mark the current batch index as checked
this.logger.info(`checked batch ok`, { this.logger.info('checked batch ok', {
batchIndex: this.state.currentBatchIndex, batchIndex: this.state.currentBatchIndex,
timeMs: elapsedMs,
}) })
this.metrics.highestBatchIndex.set( this.metrics.highestBatchIndex.set(
{ {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment