track worker liveness

Author: paulwe

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)

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)                                   {}