From 8e78664b87bc88115705fc0d0d8080579017ba58 Mon Sep 17 00:00:00 2001
From: shishir gowda <shishir@livekit.io>
Date: Fri, 13 Feb 2026 08:40:11 +0530
Subject: [PATCH] update obs for bargein

---
 observability/gatewayobs/gen_reporter.go      |  4 +++-
 observability/gatewayobs/gen_reporter_noop.go | 24 ++++++++++---------
 observability/gatewayobs/gen_source.go        |  8 +++++++
 3 files changed, 24 insertions(+), 12 deletions(-)

diff --git a/observability/gatewayobs/gen_reporter.go b/observability/gatewayobs/gen_reporter.go
index dfd3b4fc4..071937812 100644
--- a/observability/gatewayobs/gen_reporter.go
+++ b/observability/gatewayobs/gen_reporter.go
@@ -6,7 +6,7 @@ import (
 	"time"
 )
 
-const Version_J2LFGS0 = true
+const Version_PKGHM18 = true
 
 type KeyResolver interface {
 	Resolve(string)
@@ -49,6 +49,8 @@ type ModelTx interface {
 	ReportInferenceCacheReadTokens(v uint64)
 	ReportSttDuration(v uint32)
 	ReportTtsChars(v uint32)
+	ReportBargeInRequests(v uint64)
+	ReportBargeInRequestTypes(v ModelBargeInRequestTypes)
 }
 
 type ModelReporter interface {
diff --git a/observability/gatewayobs/gen_reporter_noop.go b/observability/gatewayobs/gen_reporter_noop.go
index ae96ff614..e8278b5c7 100644
--- a/observability/gatewayobs/gen_reporter_noop.go
+++ b/observability/gatewayobs/gen_reporter_noop.go
@@ -70,14 +70,16 @@ func NewNoopModelReporter() ModelReporter {
 	return &noopModelReporter{}
 }
 
-func (r *noopModelReporter) RegisterFunc(f func(ts time.Time, tx ModelTx) bool) {}
-func (r *noopModelReporter) Tx(f func(ModelTx))                                 {}
-func (r *noopModelReporter) TxAt(ts time.Time, f func(ModelTx))                 {}
-func (r *noopModelReporter) ReportInferencePromptTokens(v uint64)               {}
-func (r *noopModelReporter) ReportInferencePromptCacheTokens(v uint64)          {}
-func (r *noopModelReporter) ReportInferenceCompletionTokens(v uint64)           {}
-func (r *noopModelReporter) ReportInferenceTotalTokens(v uint64)                {}
-func (r *noopModelReporter) ReportInferenceCacheCreateTokens(v uint64)          {}
-func (r *noopModelReporter) ReportInferenceCacheReadTokens(v uint64)            {}
-func (r *noopModelReporter) ReportSttDuration(v uint32)                         {}
-func (r *noopModelReporter) ReportTtsChars(v uint32)                            {}
+func (r *noopModelReporter) RegisterFunc(f func(ts time.Time, tx ModelTx) bool)   {}
+func (r *noopModelReporter) Tx(f func(ModelTx))                                   {}
+func (r *noopModelReporter) TxAt(ts time.Time, f func(ModelTx))                   {}
+func (r *noopModelReporter) ReportInferencePromptTokens(v uint64)                 {}
+func (r *noopModelReporter) ReportInferencePromptCacheTokens(v uint64)            {}
+func (r *noopModelReporter) ReportInferenceCompletionTokens(v uint64)             {}
+func (r *noopModelReporter) ReportInferenceTotalTokens(v uint64)                  {}
+func (r *noopModelReporter) ReportInferenceCacheCreateTokens(v uint64)            {}
+func (r *noopModelReporter) ReportInferenceCacheReadTokens(v uint64)              {}
+func (r *noopModelReporter) ReportSttDuration(v uint32)                           {}
+func (r *noopModelReporter) ReportTtsChars(v uint32)                              {}
+func (r *noopModelReporter) ReportBargeInRequests(v uint64)                       {}
+func (r *noopModelReporter) ReportBargeInRequestTypes(v ModelBargeInRequestTypes) {}
diff --git a/observability/gatewayobs/gen_source.go b/observability/gatewayobs/gen_source.go
index 89a836c1b..0e5d9ab64 100644
--- a/observability/gatewayobs/gen_source.go
+++ b/observability/gatewayobs/gen_source.go
@@ -1,6 +1,14 @@
 // Code generated; DO NOT EDIT.
 package gatewayobs
 
+type ModelBargeInRequestTypes string
+
+const (
+	ModelBargeInRequestTypesUndefined  ModelBargeInRequestTypes = ""
+	ModelBargeInRequestTypesCloud      ModelBargeInRequestTypes = "cloud"
+	ModelBargeInRequestTypesSelfHosted ModelBargeInRequestTypes = "self_hosted"
+)
+
 type Rollup string
 
 const (