diff --git a/.changeset/pretty-lobsters-reply.md b/.changeset/pretty-lobsters-reply.md new file mode 100644 index 000000000..378d8ecec --- /dev/null +++ b/.changeset/pretty-lobsters-reply.md @@ -0,0 +1,5 @@ +--- +"@livekit/protocol": patch +--- + +update agents observability codegen diff --git a/observability/agentsobs/gen_reporter.go b/observability/agentsobs/gen_reporter.go index 891436158..6f7cc746b 100644 --- a/observability/agentsobs/gen_reporter.go +++ b/observability/agentsobs/gen_reporter.go @@ -6,7 +6,7 @@ import ( "time" ) -const Version_P0N4MSO = true +const Version_VKTOC48 = true type KeyResolver interface { Resolve(string) @@ -57,6 +57,7 @@ type WorkerReporter interface { ReportLoad(v float32) ReportStatus(v WorkerStatus) ReportStartTime(v time.Time) + ReportEndTime(v time.Time) ReportJobsCurrent(v uint32) ReportLive(v uint8) ReportCPU(v int64) @@ -73,6 +74,7 @@ type WorkerTx interface { ReportLoad(v float32) ReportStatus(v WorkerStatus) ReportStartTime(v time.Time) + ReportEndTime(v time.Time) ReportJobsCurrent(v uint32) ReportLive(v uint8) ReportCPU(v int64) diff --git a/observability/agentsobs/gen_reporter_noop.go b/observability/agentsobs/gen_reporter_noop.go index 342e784d5..09a5a595e 100644 --- a/observability/agentsobs/gen_reporter_noop.go +++ b/observability/agentsobs/gen_reporter_noop.go @@ -94,6 +94,7 @@ func (r *noopWorkerReporter) TxAt(ts time.Time, f func(WorkerTx)) func (r *noopWorkerReporter) ReportLoad(v float32) {} func (r *noopWorkerReporter) ReportStatus(v WorkerStatus) {} func (r *noopWorkerReporter) ReportStartTime(v time.Time) {} +func (r *noopWorkerReporter) ReportEndTime(v time.Time) {} func (r *noopWorkerReporter) ReportJobsCurrent(v uint32) {} func (r *noopWorkerReporter) ReportLive(v uint8) {} func (r *noopWorkerReporter) ReportCPU(v int64) {}