From 5c28da10310a2fdebbb65209651105635561f5b4 Mon Sep 17 00:00:00 2001 From: Brian Gough Date: Mon, 6 Apr 2020 16:24:10 +0100 Subject: [PATCH] add metric for pendingUpdates queue --- services/real-time/app/coffee/DocumentUpdaterManager.coffee | 3 +++ .../test/unit/coffee/DocumentUpdaterManagerTests.coffee | 1 + 2 files changed, 4 insertions(+) diff --git a/services/real-time/app/coffee/DocumentUpdaterManager.coffee b/services/real-time/app/coffee/DocumentUpdaterManager.coffee index bec80fae34..c5c5a67cb7 100644 --- a/services/real-time/app/coffee/DocumentUpdaterManager.coffee +++ b/services/real-time/app/coffee/DocumentUpdaterManager.coffee @@ -72,6 +72,9 @@ module.exports = DocumentUpdaterManager = error.updateSize = updateSize return callback(error) + # record metric for each update added to queue + metrics.summary 'redis.pendingUpdates', updateSize, {status: 'push'} + doc_key = "#{project_id}:#{doc_id}" # Push onto pendingUpdates for doc_id first, because once the doc updater # gets an entry on pending-updates-list, it starts processing. diff --git a/services/real-time/test/unit/coffee/DocumentUpdaterManagerTests.coffee b/services/real-time/test/unit/coffee/DocumentUpdaterManagerTests.coffee index a6bf0a5e47..aa4600d757 100644 --- a/services/real-time/test/unit/coffee/DocumentUpdaterManagerTests.coffee +++ b/services/real-time/test/unit/coffee/DocumentUpdaterManagerTests.coffee @@ -25,6 +25,7 @@ describe 'DocumentUpdaterManager', -> 'request': @request = {} 'redis-sharelatex' : createClient: () => @rclient 'metrics-sharelatex': @Metrics = + summary: sinon.stub() Timer: class Timer done: () -> globals: