From 6cedf7e38e21b65608d2f00aeeab6d102b663da2 Mon Sep 17 00:00:00 2001 From: Paul Wells Date: Thu, 14 Aug 2025 10:53:56 -0700 Subject: [PATCH] track worker liveness (#1170) --- observability/agentsobs/gen_reporter.go | 4 +++- observability/agentsobs/gen_reporter_noop.go | 1 + 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/observability/agentsobs/gen_reporter.go b/observability/agentsobs/gen_reporter.go index 9cce05c..8914361 100644 --- a/observability/agentsobs/gen_reporter.go +++ b/observability/agentsobs/gen_reporter.go @@ -6,7 +6,7 @@ import ( "time" ) -const Version_6JD79I0 = true +const Version_P0N4MSO = true type KeyResolver interface { Resolve(string) @@ -58,6 +58,7 @@ type WorkerReporter interface { ReportStatus(v WorkerStatus) ReportStartTime(v time.Time) ReportJobsCurrent(v uint32) + ReportLive(v uint8) ReportCPU(v int64) ReportCPULimit(v int64) ReportMem(v int64) @@ -73,6 +74,7 @@ type WorkerTx interface { ReportStatus(v WorkerStatus) ReportStartTime(v time.Time) ReportJobsCurrent(v uint32) + ReportLive(v uint8) ReportCPU(v int64) ReportCPULimit(v int64) ReportMem(v int64) diff --git a/observability/agentsobs/gen_reporter_noop.go b/observability/agentsobs/gen_reporter_noop.go index 0f5e71d..342e784 100644 --- a/observability/agentsobs/gen_reporter_noop.go +++ b/observability/agentsobs/gen_reporter_noop.go @@ -95,6 +95,7 @@ func (r *noopWorkerReporter) ReportLoad(v float32) func (r *noopWorkerReporter) ReportStatus(v WorkerStatus) {} func (r *noopWorkerReporter) ReportStartTime(v time.Time) {} func (r *noopWorkerReporter) ReportJobsCurrent(v uint32) {} +func (r *noopWorkerReporter) ReportLive(v uint8) {} func (r *noopWorkerReporter) ReportCPU(v int64) {} func (r *noopWorkerReporter) ReportCPULimit(v int64) {} func (r *noopWorkerReporter) ReportMem(v int64) {}