Browse Source

Add method to get number of queued project updates

Michael Walker 8 years ago
parent
commit
3d313ebc53
1 changed files with 3 additions and 0 deletions
  1. 3 0
      services/document-updater/app/coffee/RedisManager.coffee

+ 3 - 0
services/document-updater/app/coffee/RedisManager.coffee

@@ -315,6 +315,9 @@ module.exports = RedisManager =
 
 		rclient.rpush projectHistoryKeys.projectHistoryOps({project_id}), jsonUpdate, callback
 
+	numQueuedProjectUpdates: (project_id, callback = (error, length) ->) ->
+		rclient.llen projectHistoryKeys.projectHistoryOps({project_id}), callback
+
 	clearUnflushedTime: (doc_id, callback = (error) ->) ->
 		rclient.del keys.unflushedTime(doc_id:doc_id), callback