set worker kind for agent jobs (#1140)

* set worker kind for agent jobs

* generated protobuf

---------

Co-authored-by: github-actions <41898282+github-actions[bot]@users.noreply.github.com>

Author: paulwe

observability/agentsobs/gen_reporter.go

@@ -58,7 +58,6 @@ type WorkerReporter interface {
 	ReportStatus(v WorkerStatus)
 	ReportStartTime(v time.Time)
 	ReportJobsCurrent(v uint32)
-	ReportKind(v AgentKind)
 	ReportCPU(v int64)
 	ReportCPULimit(v int64)
 	ReportMem(v int64)
@@ -74,7 +73,6 @@ type WorkerTx interface {
 	ReportStatus(v WorkerStatus)
 	ReportStartTime(v time.Time)
 	ReportJobsCurrent(v uint32)
-	ReportKind(v AgentKind)
 	ReportCPU(v int64)
 	ReportCPULimit(v int64)
 	ReportMem(v int64)
@@ -91,6 +89,7 @@ type JobReporter interface {
 	TxAt(time.Time, func(tx JobTx))
 	ReportRoomSessionID(v string)
 	ReportKind(v JobKind)
+	ReportWorkerKind(v WorkerKind)
 	ReportStatus(v JobStatus)
 	ReportDuration(v uint32)
 	ReportDurationMinutes(v uint8)
@@ -102,6 +101,7 @@ type JobReporter interface {
 type JobTx interface {
 	ReportRoomSessionID(v string)
 	ReportKind(v JobKind)
+	ReportWorkerKind(v WorkerKind)
 	ReportStatus(v JobStatus)
 	ReportDuration(v uint32)
 	ReportDurationMinutes(v uint8)

observability/agentsobs/gen_reporter_noop.go

@@ -95,7 +95,6 @@ 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) ReportKind(v AgentKind)                              {}
 func (r *noopWorkerReporter) ReportCPU(v int64)                                   {}
 func (r *noopWorkerReporter) ReportCPULimit(v int64)                              {}
 func (r *noopWorkerReporter) ReportMem(v int64)                                   {}
@@ -122,6 +121,7 @@ func (r *noopJobReporter) Tx(f func(JobTx))                                 {}
 func (r *noopJobReporter) TxAt(ts time.Time, f func(JobTx))                 {}
 func (r *noopJobReporter) ReportRoomSessionID(v string)                     {}
 func (r *noopJobReporter) ReportKind(v JobKind)                             {}
+func (r *noopJobReporter) ReportWorkerKind(v WorkerKind)                    {}
 func (r *noopJobReporter) ReportStatus(v JobStatus)                         {}
 func (r *noopJobReporter) ReportDuration(v uint32)                          {}
 func (r *noopJobReporter) ReportDurationMinutes(v uint8)                    {}

observability/agentsobs/gen_source.go

@@ -9,14 +9,6 @@ const (
 	WorkerStatusFull      WorkerStatus = "full"
 )
 
-type AgentKind string
-
-const (
-	AgentKindUndefined AgentKind = ""
-	AgentKindCloud     AgentKind = "cloud"
-	AgentKindSelfhost  AgentKind = "selfhost"
-)
-
 type WorkerState string
 
 const (
@@ -34,6 +26,14 @@ const (
 	JobKindParticipant JobKind = "participant"
 )
 
+type WorkerKind string
+
+const (
+	WorkerKindUndefined WorkerKind = ""
+	WorkerKindCloud     WorkerKind = "cloud"
+	WorkerKindSelfhost  WorkerKind = "selfhost"
+)
+
 type JobStatus string
 
 const (