From 7ace4ffac1b611010ed6e565922b9bc3edfd1a76 Mon Sep 17 00:00:00 2001 From: shishir gowda Date: Tue, 6 Jan 2026 17:31:12 -0500 Subject: [PATCH] update rooms obs Signed-off-by: shishir gowda --- observability/roomobs/gen_reporter.go | 6 +++++- observability/roomobs/gen_reporter_noop.go | 4 ++++ observability/roomobs/gen_source.go | 1 + 3 files changed, 10 insertions(+), 1 deletion(-) diff --git a/observability/roomobs/gen_reporter.go b/observability/roomobs/gen_reporter.go index 34fe67e8b..060feb5b3 100644 --- a/observability/roomobs/gen_reporter.go +++ b/observability/roomobs/gen_reporter.go @@ -6,7 +6,7 @@ import ( "time" ) -const Version_DU7NGRG = true +const Version_LJB5KQG = true type KeyResolver interface { Resolve(string) @@ -44,6 +44,7 @@ type RoomSessionTx interface { ReportStartTime(v time.Time) ReportEndTime(v time.Time) ReportFeatures(v uint16) + ReportRoomDuration(v uint32) } type RoomSessionReporter interface { @@ -81,6 +82,9 @@ type ParticipantSessionTx interface { ReportEndTime(v time.Time) ReportDuration(v uint16) ReportDurationMinutes(v uint8) + ReportKind(v string) + ReportName(v string) + ReportFeatures(v uint16) } type ParticipantSessionReporter interface { diff --git a/observability/roomobs/gen_reporter_noop.go b/observability/roomobs/gen_reporter_noop.go index 50453b20a..8c53d3176 100644 --- a/observability/roomobs/gen_reporter_noop.go +++ b/observability/roomobs/gen_reporter_noop.go @@ -79,6 +79,7 @@ func (r *noopRoomSessionReporter) TxAt(ts time.Time, f func(RoomSessionTx)) func (r *noopRoomSessionReporter) ReportStartTime(v time.Time) {} func (r *noopRoomSessionReporter) ReportEndTime(v time.Time) {} func (r *noopRoomSessionReporter) ReportFeatures(v uint16) {} +func (r *noopRoomSessionReporter) ReportRoomDuration(v uint32) {} func (r *noopRoomSessionReporter) WithParticipant(identity string) ParticipantReporter { return &noopParticipantReporter{} } @@ -126,6 +127,9 @@ func (r *noopParticipantSessionReporter) ReportStartTime(v time.Time) func (r *noopParticipantSessionReporter) ReportEndTime(v time.Time) {} func (r *noopParticipantSessionReporter) ReportDuration(v uint16) {} func (r *noopParticipantSessionReporter) ReportDurationMinutes(v uint8) {} +func (r *noopParticipantSessionReporter) ReportKind(v string) {} +func (r *noopParticipantSessionReporter) ReportName(v string) {} +func (r *noopParticipantSessionReporter) ReportFeatures(v uint16) {} func (r *noopParticipantSessionReporter) WithTrack(id string) TrackReporter { return &noopTrackReporter{} } diff --git a/observability/roomobs/gen_source.go b/observability/roomobs/gen_source.go index d34b0b5e3..0d8b3aa87 100644 --- a/observability/roomobs/gen_source.go +++ b/observability/roomobs/gen_source.go @@ -81,6 +81,7 @@ type Rollup string const ( RollupUndefined Rollup = "" RollupProject Rollup = "project" + RollupRoomSession Rollup = "room_session" RollupRoomSessionIndex Rollup = "room_session_index" RollupParticipantIndex Rollup = "participant_index" RollupParticipantSessionIndex Rollup = "participant_session_index"