From 346b8c24a86605e81afd772b3aef12155f85796c Mon Sep 17 00:00:00 2001 From: Paul Wells Date: Sat, 2 May 2026 06:39:34 -0700 Subject: [PATCH 1/2] update observability codegen for ingress/egress --- observability/egressobs/gen_reporter.go | 3 ++- observability/egressobs/gen_reporter_noop.go | 2 ++ observability/ingressobs/gen_reporter.go | 3 ++- observability/ingressobs/gen_reporter_noop.go | 2 ++ 4 files changed, 8 insertions(+), 2 deletions(-) diff --git a/observability/egressobs/gen_reporter.go b/observability/egressobs/gen_reporter.go index 3ef2b9890..668db987c 100644 --- a/observability/egressobs/gen_reporter.go +++ b/observability/egressobs/gen_reporter.go @@ -6,7 +6,7 @@ import ( "time" ) -const Version_9K0LIKO = true +const Version_HAKUONO = true type KeyResolver interface { Resolve(string) @@ -69,6 +69,7 @@ type sessionReporter interface { ReportEndTime(v time.Time) ReportUpdateTime(v time.Time) ReportDuration(v uint64) + ReportDurationSeconds(v uint64) ReportRetryCount(v uint32) ReportSourceType(v SessionSourceType) ReportRegion(v string) diff --git a/observability/egressobs/gen_reporter_noop.go b/observability/egressobs/gen_reporter_noop.go index 7b00af3b0..961e69649 100644 --- a/observability/egressobs/gen_reporter_noop.go +++ b/observability/egressobs/gen_reporter_noop.go @@ -115,6 +115,7 @@ func (r *noopSessionReporter) ReportStartTime(v time.Time) func (r *noopSessionReporter) ReportEndTime(v time.Time) {} func (r *noopSessionReporter) ReportUpdateTime(v time.Time) {} func (r *noopSessionReporter) ReportDuration(v uint64) {} +func (r *noopSessionReporter) ReportDurationSeconds(v uint64) {} func (r *noopSessionReporter) ReportRetryCount(v uint32) {} func (r *noopSessionReporter) ReportSourceType(v SessionSourceType) {} func (r *noopSessionReporter) ReportRegion(v string) {} @@ -137,6 +138,7 @@ func (t *noopSessionTx) ReportStartTime(v time.Time) {} func (t *noopSessionTx) ReportEndTime(v time.Time) {} func (t *noopSessionTx) ReportUpdateTime(v time.Time) {} func (t *noopSessionTx) ReportDuration(v uint64) {} +func (t *noopSessionTx) ReportDurationSeconds(v uint64) {} func (t *noopSessionTx) ReportRetryCount(v uint32) {} func (t *noopSessionTx) ReportSourceType(v SessionSourceType) {} func (t *noopSessionTx) ReportRegion(v string) {} diff --git a/observability/ingressobs/gen_reporter.go b/observability/ingressobs/gen_reporter.go index 56edd5a99..7328e7e9c 100644 --- a/observability/ingressobs/gen_reporter.go +++ b/observability/ingressobs/gen_reporter.go @@ -6,7 +6,7 @@ import ( "time" ) -const Version_102PA2G = true +const Version_HPUAOT8 = true type KeyResolver interface { Resolve(string) @@ -55,6 +55,7 @@ type sessionReporter interface { ReportStartTime(v time.Time) ReportEndTime(v time.Time) ReportDuration(v uint64) + ReportDurationSeconds(v uint64) ReportInputType(v SessionInputType) ReportRegion(v string) ReportRoomName(v string) diff --git a/observability/ingressobs/gen_reporter_noop.go b/observability/ingressobs/gen_reporter_noop.go index c36cff894..dfbebec69 100644 --- a/observability/ingressobs/gen_reporter_noop.go +++ b/observability/ingressobs/gen_reporter_noop.go @@ -87,6 +87,7 @@ func (r *noopSessionReporter) TxAt(ts time.Time, f func(SessionTx)) func (r *noopSessionReporter) ReportStartTime(v time.Time) {} func (r *noopSessionReporter) ReportEndTime(v time.Time) {} func (r *noopSessionReporter) ReportDuration(v uint64) {} +func (r *noopSessionReporter) ReportDurationSeconds(v uint64) {} func (r *noopSessionReporter) ReportInputType(v SessionInputType) {} func (r *noopSessionReporter) ReportRegion(v string) {} func (r *noopSessionReporter) ReportRoomName(v string) {} @@ -106,6 +107,7 @@ func (t *noopSessionTx) Ingress() IngressTx { func (t *noopSessionTx) ReportStartTime(v time.Time) {} func (t *noopSessionTx) ReportEndTime(v time.Time) {} func (t *noopSessionTx) ReportDuration(v uint64) {} +func (t *noopSessionTx) ReportDurationSeconds(v uint64) {} func (t *noopSessionTx) ReportInputType(v SessionInputType) {} func (t *noopSessionTx) ReportRegion(v string) {} func (t *noopSessionTx) ReportRoomName(v string) {} From 05aa5fde436254bdf9986232f269e8650c3f4838 Mon Sep 17 00:00:00 2001 From: Paul Wells Date: Sat, 2 May 2026 06:41:09 -0700 Subject: [PATCH 2/2] Update observability codegen for ingress/egress Update observability code generation for ingress and egress. --- .changeset/brown-plums-tie.md | 5 +++++ 1 file changed, 5 insertions(+) create mode 100644 .changeset/brown-plums-tie.md diff --git a/.changeset/brown-plums-tie.md b/.changeset/brown-plums-tie.md new file mode 100644 index 000000000..da5c07a39 --- /dev/null +++ b/.changeset/brown-plums-tie.md @@ -0,0 +1,5 @@ +--- +"@livekit/protocol": patch +--- + +update observability codegen for ingress/egress