Skip to content

Commit 96f2812

Browse files
authored
update agents observability codegen (#1173)
* update agents observability codegen * Create pretty-lobsters-reply.md * update
1 parent 72e862b commit 96f2812

File tree

3 files changed

+9
-1
lines changed

3 files changed

+9
-1
lines changed
Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
---
2+
"@livekit/protocol": patch
3+
---
4+
5+
update agents observability codegen

observability/agentsobs/gen_reporter.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@ import (
66
"time"
77
)
88

9-
const Version_P0N4MSO = true
9+
const Version_VKTOC48 = true
1010

1111
type KeyResolver interface {
1212
Resolve(string)
@@ -57,6 +57,7 @@ type WorkerReporter interface {
5757
ReportLoad(v float32)
5858
ReportStatus(v WorkerStatus)
5959
ReportStartTime(v time.Time)
60+
ReportEndTime(v time.Time)
6061
ReportJobsCurrent(v uint32)
6162
ReportLive(v uint8)
6263
ReportCPU(v int64)
@@ -73,6 +74,7 @@ type WorkerTx interface {
7374
ReportLoad(v float32)
7475
ReportStatus(v WorkerStatus)
7576
ReportStartTime(v time.Time)
77+
ReportEndTime(v time.Time)
7678
ReportJobsCurrent(v uint32)
7779
ReportLive(v uint8)
7880
ReportCPU(v int64)

observability/agentsobs/gen_reporter_noop.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -94,6 +94,7 @@ func (r *noopWorkerReporter) TxAt(ts time.Time, f func(WorkerTx))
9494
func (r *noopWorkerReporter) ReportLoad(v float32) {}
9595
func (r *noopWorkerReporter) ReportStatus(v WorkerStatus) {}
9696
func (r *noopWorkerReporter) ReportStartTime(v time.Time) {}
97+
func (r *noopWorkerReporter) ReportEndTime(v time.Time) {}
9798
func (r *noopWorkerReporter) ReportJobsCurrent(v uint32) {}
9899
func (r *noopWorkerReporter) ReportLive(v uint8) {}
99100
func (r *noopWorkerReporter) ReportCPU(v int64) {}

0 commit comments

Comments
 (0)