From aa52304fe86a913b039da64ce399db162813c3bc Mon Sep 17 00:00:00 2001 From: barrust Date: Tue, 21 Oct 2025 09:51:01 -0400 Subject: [PATCH 1/2] update otel observability --- observability/otelobs/gen_reporter.go | 3 +-- observability/otelobs/gen_reporter_noop.go | 1 - 2 files changed, 1 insertion(+), 3 deletions(-) diff --git a/observability/otelobs/gen_reporter.go b/observability/otelobs/gen_reporter.go index 1babbaae..7c2a5232 100644 --- a/observability/otelobs/gen_reporter.go +++ b/observability/otelobs/gen_reporter.go @@ -6,7 +6,7 @@ import ( "time" ) -const Version_2AT6MB8 = true +const Version_SJLS0N0 = true type KeyResolver interface { Resolve(string) @@ -32,7 +32,6 @@ type ProjectReporter interface { type SourceTx interface { ReportDataType(v DataType) ReportBytes(v uint64) - ReportDuration(v uint64) ReportAllowedForTraining(v bool) } diff --git a/observability/otelobs/gen_reporter_noop.go b/observability/otelobs/gen_reporter_noop.go index 4a22c4c8..262d260b 100644 --- a/observability/otelobs/gen_reporter_noop.go +++ b/observability/otelobs/gen_reporter_noop.go @@ -58,5 +58,4 @@ func (r *noopSourceReporter) Tx(f func(SourceTx)) func (r *noopSourceReporter) TxAt(ts time.Time, f func(SourceTx)) {} func (r *noopSourceReporter) ReportDataType(v DataType) {} func (r *noopSourceReporter) ReportBytes(v uint64) {} -func (r *noopSourceReporter) ReportDuration(v uint64) {} func (r *noopSourceReporter) ReportAllowedForTraining(v bool) {} From b23f4ab0d75697eb1bf94aab228646f99d0d1bbb Mon Sep 17 00:00:00 2001 From: barrust Date: Tue, 21 Oct 2025 14:21:16 -0400 Subject: [PATCH 2/2] remove otelobs --- observability/otelobs/gen_reporter.go | 43 --------------- observability/otelobs/gen_reporter_noop.go | 61 ---------------------- observability/otelobs/gen_source.go | 19 ------- 3 files changed, 123 deletions(-) delete mode 100644 observability/otelobs/gen_reporter.go delete mode 100644 observability/otelobs/gen_reporter_noop.go delete mode 100644 observability/otelobs/gen_source.go diff --git a/observability/otelobs/gen_reporter.go b/observability/otelobs/gen_reporter.go deleted file mode 100644 index 7c2a5232..00000000 --- a/observability/otelobs/gen_reporter.go +++ /dev/null @@ -1,43 +0,0 @@ -// Code generated; DO NOT EDIT. - -package otelobs - -import ( - "time" -) - -const Version_SJLS0N0 = true - -type KeyResolver interface { - Resolve(string) - Reset() -} - -type Reporter interface { - WithProject(id string) ProjectReporter - WithDeferredProject() (ProjectReporter, KeyResolver) -} - -type ProjectTx interface{} - -type ProjectReporter interface { - RegisterFunc(func(ts time.Time, tx ProjectTx) bool) - Tx(func(tx ProjectTx)) - TxAt(time.Time, func(tx ProjectTx)) - WithSource(name string) SourceReporter - WithDeferredSource() (SourceReporter, KeyResolver) - ProjectTx -} - -type SourceTx interface { - ReportDataType(v DataType) - ReportBytes(v uint64) - ReportAllowedForTraining(v bool) -} - -type SourceReporter interface { - RegisterFunc(func(ts time.Time, tx SourceTx) bool) - Tx(func(tx SourceTx)) - TxAt(time.Time, func(tx SourceTx)) - SourceTx -} diff --git a/observability/otelobs/gen_reporter_noop.go b/observability/otelobs/gen_reporter_noop.go deleted file mode 100644 index 262d260b..00000000 --- a/observability/otelobs/gen_reporter_noop.go +++ /dev/null @@ -1,61 +0,0 @@ -// Code generated; DO NOT EDIT. - -package otelobs - -import ( - "time" -) - -var ( - _ Reporter = (*noopReporter)(nil) - _ ProjectReporter = (*noopProjectReporter)(nil) - _ SourceReporter = (*noopSourceReporter)(nil) -) - -type noopKeyResolver struct{} - -func (noopKeyResolver) Resolve(string) {} -func (noopKeyResolver) Reset() {} - -type noopReporter struct{} - -func NewNoopReporter() Reporter { - return &noopReporter{} -} - -func (r *noopReporter) WithProject(id string) ProjectReporter { - return &noopProjectReporter{} -} - -func (r *noopReporter) WithDeferredProject() (ProjectReporter, KeyResolver) { - return &noopProjectReporter{}, noopKeyResolver{} -} - -type noopProjectReporter struct{} - -func NewNoopProjectReporter() ProjectReporter { - return &noopProjectReporter{} -} - -func (r *noopProjectReporter) RegisterFunc(f func(ts time.Time, tx ProjectTx) bool) {} -func (r *noopProjectReporter) Tx(f func(ProjectTx)) {} -func (r *noopProjectReporter) TxAt(ts time.Time, f func(ProjectTx)) {} -func (r *noopProjectReporter) WithSource(name string) SourceReporter { - return &noopSourceReporter{} -} -func (r *noopProjectReporter) WithDeferredSource() (SourceReporter, KeyResolver) { - return &noopSourceReporter{}, noopKeyResolver{} -} - -type noopSourceReporter struct{} - -func NewNoopSourceReporter() SourceReporter { - return &noopSourceReporter{} -} - -func (r *noopSourceReporter) RegisterFunc(f func(ts time.Time, tx SourceTx) bool) {} -func (r *noopSourceReporter) Tx(f func(SourceTx)) {} -func (r *noopSourceReporter) TxAt(ts time.Time, f func(SourceTx)) {} -func (r *noopSourceReporter) ReportDataType(v DataType) {} -func (r *noopSourceReporter) ReportBytes(v uint64) {} -func (r *noopSourceReporter) ReportAllowedForTraining(v bool) {} diff --git a/observability/otelobs/gen_source.go b/observability/otelobs/gen_source.go deleted file mode 100644 index f555e2b6..00000000 --- a/observability/otelobs/gen_source.go +++ /dev/null @@ -1,19 +0,0 @@ -// Code generated; DO NOT EDIT. -package otelobs - -type DataType string - -const ( - DataTypeUndefined DataType = "" - DataTypeRecording DataType = "recording" - DataTypeTrace DataType = "trace" - DataTypeLog DataType = "log" - DataTypeMetric DataType = "metric" -) - -type Rollup string - -const ( - RollupUndefined Rollup = "" - RollupSource Rollup = "source" -)