Add built-in awaiting metric for monitoring stats

HangfireIO · Jan 25, 2023 · e9d018c · e9d018c
1 parent af9c7e6
commit e9d018c
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 3 deletions.
diff --git a/src/Hangfire.Core/Dashboard/DashboardMetrics.cs b/src/Hangfire.Core/Dashboard/DashboardMetrics.cs
@@ -182,11 +182,18 @@ public static IEnumerable<DashboardMetric> GetMetrics()
             {
                 long awaitingCount = -1;
 
-                using (var connection = page.Storage.GetReadOnlyConnection())
+                if (page.Statistics.Awaiting.HasValue)
                 {
-                    if (connection is JobStorageConnection storageConnection)
+                    awaitingCount = page.Statistics.Awaiting.Value;
+                }
+                else
+                {
+                    using (var connection = page.Storage.GetReadOnlyConnection())
                     {
-                        awaitingCount = storageConnection.GetSetCount("awaiting");
+                        if (connection is JobStorageConnection storageConnection)
+                        {
+                            awaitingCount = storageConnection.GetSetCount("awaiting");
+                        }
                     }
                 }
 

diff --git a/src/Hangfire.Core/Storage/Monitoring/StatisticsDto.cs b/src/Hangfire.Core/Storage/Monitoring/StatisticsDto.cs
@@ -27,5 +27,6 @@ public class StatisticsDto
         public long Failed { get; set; }
         public long Deleted { get; set; }
         public long? Retries { get; set; }
+        public long? Awaiting { get; set; }
     }
 }
diff --git a/src/Hangfire.SqlServer/SqlServerMonitoringApi.cs b/src/Hangfire.SqlServer/SqlServerMonitoringApi.cs
@@ -408,6 +408,7 @@ public override StatisticsDto GetStatistics()
 select count(Id) from [{0}].Job with (nolock, forceseek) where StateName = N'Failed';
 select count(Id) from [{0}].Job with (nolock, forceseek) where StateName = N'Processing';
 select count(Id) from [{0}].Job with (nolock, forceseek) where StateName = N'Scheduled';
+select count(Id) from [{0}].Job with (nolock, forceseek) where StateName = N'Awaiting';
 select count(Id) from [{0}].Server with (nolock);
 select sum(s.[Value]) from (
     select sum([Value]) as [Value] from [{0}].Counter with (nolock, forceseek) where [Key] = N'stats:succeeded'
@@ -433,6 +434,7 @@ union all
                     stats.Failed = multi.ReadSingle<int>();
                     stats.Processing = multi.ReadSingle<int>();
                     stats.Scheduled = multi.ReadSingle<int>();
+                    stats.Awaiting = multi.ReadSingle<int>();
 
                     stats.Servers = multi.ReadSingle<int>();