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