admin/sockeye
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
John Cardinal
2023-01-19 02:00:26 +00:00
parent a5993f4570
commit 9800d5a672
2 changed files with 6 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
server/biz/JobsBiz.cs
View File

@@ -261,10 +261,8 @@ namespace Sockeye.Biz
if (!KeepOnWorking()) return; if (!KeepOnWorking()) return;
//SOCKBOT - SUBSCRIPTION SERVER HEALTH CHECKS //SOCKBOT - SUBSCRIPTION SERVER HEALTH CHECKS
await SockBotSubscriptionServerHealthChecks.DoWorkAsync();
if (!KeepOnWorking()) return;
//JOB SWEEPER //JOB SWEEPER
await CoreJobSweeper.DoWorkAsync(); await CoreJobSweeper.DoWorkAsync();

7
server/generator/SockBotSubscriptionServerHealthChecks.cs
View File

@@ -12,14 +12,14 @@ namespace Sockeye.Biz
/// <summary> /// <summary>
/// Check the health of subscribers servers, basically a ping check /// Check the health of subscribers servers using the /health endpoint
/// trigger notification if any fail the test excessively (some slack for intermittent comm. issues) /// trigger notification if any fail the test 3 times (some slack for intermittent comm. issues)
/// </summary> /// </summary>
internal static class SockBotSubscriptionServerHealthChecks internal static class SockBotSubscriptionServerHealthChecks
{ {
private static ILogger log = Sockeye.Util.ApplicationLogging.CreateLogger("SockBotSubscriptionServerHealthChecks"); private static ILogger log = Sockeye.Util.ApplicationLogging.CreateLogger("SockBotSubscriptionServerHealthChecks");
private static DateTime lastSweep = DateTime.MinValue; private static DateTime lastSweep = DateTime.MinValue;
private static TimeSpan HEALTHCHECK_EVERY_INTERVAL = new TimeSpan(0, 15, 10);//every 15 minutes roughly private static TimeSpan HEALTHCHECK_EVERY_INTERVAL = new TimeSpan(0, 5, 10);//every 5 minutes roughly meaning 15 minutes down is highest fail state
//////////////////////////////////////////////////////////////////////////////////////////////// ////////////////////////////////////////////////////////////////////////////////////////////////
// DoSweep // DoSweep
// //
@@ -71,6 +71,7 @@ namespace Sockeye.Biz
var responseText = await res.Content.ReadAsStringAsync(); var responseText = await res.Content.ReadAsStringAsync();
srv.LastHealthCheck = DateTime.UtcNow; srv.LastHealthCheck = DateTime.UtcNow;
srv.LastHealthStatus = responseText; srv.LastHealthStatus = responseText;
log.LogDebug($"Health check server {srv.Name} response {responseText}");
if (res.IsSuccessStatusCode && responseText == "Healthy") if (res.IsSuccessStatusCode && responseText == "Healthy")
{ {
//a-ok //a-ok