Expose Queue Depth (#49)

* Expose Queue Depth

* Renaming methods based on feedback

Fixes #48 

Co-authored-by: patri <patri@DESKTOP-KT98APM>

Author: patricker

IBackend.cs

@@ -13,6 +13,8 @@ public interface IBackend
 
         Task<IEnumerable<string>> DequeueBatch(string queueKey, int batchSize=100);
 
+        Task<long> QueueCount(string key);
+
         Task<IBackendLock> LockBlocking(string lockKey);
 
         Task<IBackendLock> LockNonBlocking(string lockKey);

RedisBackend.cs

@@ -38,6 +38,11 @@ public async Task<IEnumerable<string>> DequeueBatch(string queueKey, int batchSi
             return jsonStrings.Select(v => (string) v);
         }
 
+        public async Task<long> QueueCount(string queueKey)
+        {
+            return await RedisQueue.Count(queueKey);
+        }
+
         public async Task<IBackendLock> LockBlocking(string lockKey)
         {
             return await Redis.LockBlockingAsync(lockKey);

RedisQueue.cs

@@ -26,6 +26,11 @@ public RedisQueue(ConnectionMultiplexer redis)
             Redis = redis;
         }
 
+        public async Task<long> Count(RedisKey queueName)
+        {
+            return await Redis.GetDatabase().ListLengthAsync(queueName);
+        }
+
         public async Task Push(RedisKey queueName, RedisValue value)
         {
             await Redis.GetDatabase().ListLeftPushAsync(queueName, value);

TaskQueue.cs

@@ -43,6 +43,11 @@ internal async Task Enqueue(TaskInfo taskInfo)
 
             await Backend.Enqueue(Config.QueueName, jsonString);
         }
+
+        public async Task<long> Count()
+        {
+            return await Backend.QueueCount(Config.QueueName);
+        }
 
         public async Task<bool> ExecuteNext()
         {