From 83c0cb49431800ac45e1a90f90d63bc44d6a8499 Mon Sep 17 00:00:00 2001 From: Russell Martin Date: Thu, 27 Aug 2026 14:02:38 +0100 Subject: [PATCH 1/2] Add realtime text message reporter Expose the generated reporter method required to persist provider-billable realtime text input messages. --- observability/gatewayobs/gen_reporter.go | 3 ++- observability/gatewayobs/gen_reporter_noop.go | 2 ++ 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/observability/gatewayobs/gen_reporter.go b/observability/gatewayobs/gen_reporter.go index 3c8dee4a9..ff7c7d18f 100644 --- a/observability/gatewayobs/gen_reporter.go +++ b/observability/gatewayobs/gen_reporter.go @@ -6,7 +6,7 @@ import ( "time" ) -const Version_J1BFFVO = true +const Version_F2D2A50 = true type KeyResolver interface { Resolve(string) @@ -118,6 +118,7 @@ type modelReporter interface { ReportRealtimeOutputAudioTokens(v uint64) ReportRealtimeCachedTextTokens(v uint64) ReportRealtimeCachedAudioTokens(v uint64) + ReportRealtimeTextInputMessages(v uint64) ReportSttDuration(v uint32) ReportTtsChars(v uint32) ReportBargeInRequests(v uint64) diff --git a/observability/gatewayobs/gen_reporter_noop.go b/observability/gatewayobs/gen_reporter_noop.go index 241f1ebb6..3c5ea82a8 100644 --- a/observability/gatewayobs/gen_reporter_noop.go +++ b/observability/gatewayobs/gen_reporter_noop.go @@ -173,6 +173,7 @@ func (r *noopModelReporter) ReportRealtimeOutputTextTokens(v uint64) func (r *noopModelReporter) ReportRealtimeOutputAudioTokens(v uint64) {} func (r *noopModelReporter) ReportRealtimeCachedTextTokens(v uint64) {} func (r *noopModelReporter) ReportRealtimeCachedAudioTokens(v uint64) {} +func (r *noopModelReporter) ReportRealtimeTextInputMessages(v uint64) {} func (r *noopModelReporter) ReportSttDuration(v uint32) {} func (r *noopModelReporter) ReportTtsChars(v uint32) {} func (r *noopModelReporter) ReportBargeInRequests(v uint64) {} @@ -202,6 +203,7 @@ func (t *noopModelTx) ReportRealtimeOutputTextTokens(v uint64) {} func (t *noopModelTx) ReportRealtimeOutputAudioTokens(v uint64) {} func (t *noopModelTx) ReportRealtimeCachedTextTokens(v uint64) {} func (t *noopModelTx) ReportRealtimeCachedAudioTokens(v uint64) {} +func (t *noopModelTx) ReportRealtimeTextInputMessages(v uint64) {} func (t *noopModelTx) ReportSttDuration(v uint32) {} func (t *noopModelTx) ReportTtsChars(v uint32) {} func (t *noopModelTx) ReportBargeInRequests(v uint64) {} From 18f0a1b6197437005ac2374602ddde5f7968a517 Mon Sep 17 00:00:00 2001 From: Russell Martin Date: Thu, 27 Aug 2026 15:58:28 +0100 Subject: [PATCH 2/2] Add realtime cached image reporter Expose the generated reporter API needed to persist discounted realtime image-cache usage. --- observability/gatewayobs/gen_reporter.go | 3 ++- observability/gatewayobs/gen_reporter_noop.go | 2 ++ 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/observability/gatewayobs/gen_reporter.go b/observability/gatewayobs/gen_reporter.go index ff7c7d18f..65058b355 100644 --- a/observability/gatewayobs/gen_reporter.go +++ b/observability/gatewayobs/gen_reporter.go @@ -6,7 +6,7 @@ import ( "time" ) -const Version_F2D2A50 = true +const Version_3V1GTG0 = true type KeyResolver interface { Resolve(string) @@ -118,6 +118,7 @@ type modelReporter interface { ReportRealtimeOutputAudioTokens(v uint64) ReportRealtimeCachedTextTokens(v uint64) ReportRealtimeCachedAudioTokens(v uint64) + ReportRealtimeCachedImageTokens(v uint64) ReportRealtimeTextInputMessages(v uint64) ReportSttDuration(v uint32) ReportTtsChars(v uint32) diff --git a/observability/gatewayobs/gen_reporter_noop.go b/observability/gatewayobs/gen_reporter_noop.go index 3c5ea82a8..dbb5dfbdc 100644 --- a/observability/gatewayobs/gen_reporter_noop.go +++ b/observability/gatewayobs/gen_reporter_noop.go @@ -173,6 +173,7 @@ func (r *noopModelReporter) ReportRealtimeOutputTextTokens(v uint64) func (r *noopModelReporter) ReportRealtimeOutputAudioTokens(v uint64) {} func (r *noopModelReporter) ReportRealtimeCachedTextTokens(v uint64) {} func (r *noopModelReporter) ReportRealtimeCachedAudioTokens(v uint64) {} +func (r *noopModelReporter) ReportRealtimeCachedImageTokens(v uint64) {} func (r *noopModelReporter) ReportRealtimeTextInputMessages(v uint64) {} func (r *noopModelReporter) ReportSttDuration(v uint32) {} func (r *noopModelReporter) ReportTtsChars(v uint32) {} @@ -203,6 +204,7 @@ func (t *noopModelTx) ReportRealtimeOutputTextTokens(v uint64) {} func (t *noopModelTx) ReportRealtimeOutputAudioTokens(v uint64) {} func (t *noopModelTx) ReportRealtimeCachedTextTokens(v uint64) {} func (t *noopModelTx) ReportRealtimeCachedAudioTokens(v uint64) {} +func (t *noopModelTx) ReportRealtimeCachedImageTokens(v uint64) {} func (t *noopModelTx) ReportRealtimeTextInputMessages(v uint64) {} func (t *noopModelTx) ReportSttDuration(v uint32) {} func (t *noopModelTx) ReportTtsChars(v uint32) {}