[wip][chore] migrate away from opencensus over to otel

exporter/splunkhecexporter/documentation.md

@@ -0,0 +1,23 @@
+[comment]: <> (Code generated by mdatagen. DO NOT EDIT.)
+
+# splunk_hec
+
+## Internal Telemetry
+
+The following telemetry is emitted by this component.
+
+### otelcol_exporter_splunkhec_heartbeats_failed
+
+number of heartbeats failed
+
+| Unit | Metric Type | Value Type | Monotonic |
+| ---- | ----------- | ---------- | --------- |
+| 1 | Sum | Int | true |
+
+### otelcol_exporter_splunkhec_heartbeats_sent
+
+number of heartbeats sent
+
+| Unit | Metric Type | Value Type | Monotonic |
+| ---- | ----------- | ---------- | --------- |
+| 1 | Sum | Int | true |

exporter/splunkhecexporter/go.mod

@@ -17,13 +17,16 @@ require (
 	go.opentelemetry.io/collector/config/confighttp v0.103.0
 	go.opentelemetry.io/collector/config/configopaque v1.10.0
 	go.opentelemetry.io/collector/config/configretry v0.103.0
+	go.opentelemetry.io/collector/config/configtelemetry v0.103.0
 	go.opentelemetry.io/collector/config/configtls v0.103.0
 	go.opentelemetry.io/collector/confmap v0.103.0
 	go.opentelemetry.io/collector/consumer v0.103.0
 	go.opentelemetry.io/collector/exporter v0.103.0
 	go.opentelemetry.io/collector/pdata v1.10.0
 	go.opentelemetry.io/collector/semconv v0.103.0
+	go.opentelemetry.io/otel v1.27.0
 	go.opentelemetry.io/otel/metric v1.27.0
+	go.opentelemetry.io/otel/sdk/metric v1.27.0
 	go.opentelemetry.io/otel/trace v1.27.0
 	go.uber.org/goleak v1.3.0
 	go.uber.org/multierr v1.11.0
@@ -91,17 +94,14 @@ require (
 	go.opentelemetry.io/collector v0.103.0 // indirect
 	go.opentelemetry.io/collector/config/configauth v0.103.0 // indirect
 	go.opentelemetry.io/collector/config/configcompression v1.10.0 // indirect
-	go.opentelemetry.io/collector/config/configtelemetry v0.103.0 // indirect
 	go.opentelemetry.io/collector/config/internal v0.103.0 // indirect
 	go.opentelemetry.io/collector/extension v0.103.0 // indirect
 	go.opentelemetry.io/collector/extension/auth v0.103.0 // indirect
 	go.opentelemetry.io/collector/featuregate v1.10.0 // indirect
 	go.opentelemetry.io/collector/receiver v0.103.0 // indirect
 	go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.52.0 // indirect
-	go.opentelemetry.io/otel v1.27.0 // indirect
 	go.opentelemetry.io/otel/exporters/prometheus v0.49.0 // indirect
 	go.opentelemetry.io/otel/sdk v1.27.0 // indirect
-	go.opentelemetry.io/otel/sdk/metric v1.27.0 // indirect
 	golang.org/x/crypto v0.24.0 // indirect
 	golang.org/x/mod v0.17.0 // indirect
 	golang.org/x/net v0.26.0 // indirect

exporter/splunkhecexporter/heartbeat.go

@@ -10,21 +10,15 @@
 	"runtime"
 	"time"
 
-	"go.opencensus.io/stats"
-	"go.opencensus.io/stats/view"
-	"go.opencensus.io/tag"
 	"go.opentelemetry.io/collector/component"
 	"go.opentelemetry.io/collector/pdata/plog"
+	"go.opentelemetry.io/otel/attribute"
+	"go.opentelemetry.io/otel/metric"
 
+	"github.com/open-telemetry/opentelemetry-collector-contrib/exporter/splunkhecexporter/internal/metadata"
 	"github.com/open-telemetry/opentelemetry-collector-contrib/internal/splunk"
 )
 
-const (
-	metricsPrefix              = "otelcol_exporter_splunkhec_"
-	defaultHBSentMetricsName   = metricsPrefix + "heartbeats_sent"
-	defaultHBFailedMetricsName = metricsPrefix + "heartbeats_failed"
-)
-
 type heartbeater struct {
 	hbDoneChan chan struct{}
 }
@@ -42,46 +36,20 @@
 		return nil
 	}
 
-	var heartbeatsSent, heartbeatsFailed *stats.Int64Measure
-	var tagMutators []tag.Mutator
+	var telemetryBuilder *metadata.TelemetryBuilder
+	var attrs attribute.Set
 	if config.Telemetry.Enabled {
-		overrides := config.Telemetry.OverrideMetricsNames
+		// TODO: handle overrides, this could be done w/ views in configuration
+		// overrides := config.Telemetry.OverrideMetricsNames
 		extraAttributes := config.Telemetry.ExtraAttributes
-		var tags []tag.Key
-		tagMutators = []tag.Mutator{}
+		var attributes []attribute.KeyValue
 		for key, val := range extraAttributes {
-			newTag, _ := tag.NewKey(key)
-			tags = append(tags, newTag)
-			tagMutators = append(tagMutators, tag.Insert(newTag, val))
-		}
-
-		heartbeatsSent = stats.Int64(
-			getMetricsName(overrides, defaultHBSentMetricsName),
-			"number of heartbeats sent",
-			stats.UnitDimensionless)
-
-		heartbeatsSentView := &view.View{
-			Name:        heartbeatsSent.Name(),
-			Description: heartbeatsSent.Description(),
-			TagKeys:     tags,
-			Measure:     heartbeatsSent,
-			Aggregation: view.Sum(),
-		}
-
-		heartbeatsFailed = stats.Int64(
-			getMetricsName(overrides, defaultHBFailedMetricsName),
-			"number of heartbeats failed",
-			stats.UnitDimensionless)
-
-		heartbeatsFailedView := &view.View{
-			Name:        heartbeatsFailed.Name(),
-			Description: heartbeatsFailed.Description(),
-			TagKeys:     tags,
-			Measure:     heartbeatsFailed,
-			Aggregation: view.Sum(),
+			attributes = append(attributes, attribute.String(key, val))
 		}
+		attrs = attribute.NewSet(attributes...)
 
-		if err := view.Register(heartbeatsSentView, heartbeatsFailedView); err != nil {
+		var err error
+		if telemetryBuilder, err = metadata.NewTelemetryBuilder(); err != nil {
 			return nil
 		}
 	}
@@ -99,7 +67,7 @@
 			case <-ticker.C:
 				err := hbter.sendHeartbeat(config, buildInfo, pushLogFn)
 				if config.Telemetry.Enabled {
-					observe(heartbeatsSent, heartbeatsFailed, tagMutators, err)
+					observe(telemetryBuilder, attrs, err)
 				}
 			}
 		}
@@ -116,14 +84,11 @@
 }
 
 // there is only use case for open census metrics recording for now. Extend to use open telemetry in the future.
-func observe(heartbeatsSent *stats.Int64Measure, heartbeatsFailed *stats.Int64Measure, tagMutators []tag.Mutator, err error) {
-	var counter *stats.Int64Measure
+func observe(telemetryBuilder *metadata.TelemetryBuilder, attrs attribute.Set, err error) {
 	if err == nil {
-		counter = heartbeatsSent
-	} else {
-		counter = heartbeatsFailed
+		telemetryBuilder.OtelcolExporterSplunkhecHeartbeatsSent.Add(context.Background(), 1, metric.WithAttributeSet(attrs))
 	}
-	_ = stats.RecordWithTags(context.Background(), tagMutators, counter.M(1))
+	telemetryBuilder.OtelcolExporterSplunkhecHeartbeatsFailed.Add(context.Background(), 1, metric.WithAttributeSet(attrs))
 }
 
 func generateHeartbeatLog(hecToOtelAttrs splunk.HecToOtelAttrs, buildInfo component.BuildInfo) plog.Logs {

exporter/splunkhecexporter/metadata.yaml

@@ -17,8 +17,20 @@ tests:
     retry_on_failure:
       enabled: false
   expect_consumer_error: true
-  goleak:
-    ignore:
-      top:
-        # See https://github.com/census-instrumentation/opencensus-go/issues/1191 for more information.
-        - "go.opencensus.io/stats/view.(*worker).start"
+
+telemetry:
+  metrics:
+    otelcol_exporter_splunkhec_heartbeats_sent:
+      enabled: true
+      description: number of heartbeats sent
+      unit: "1"
+      sum:
+        value_type: int
+        monotonic: true
+    otelcol_exporter_splunkhec_heartbeats_failed:
+      enabled: true
+      description: number of heartbeats failed
+      unit: "1"
+      sum:
+        value_type: int
+        monotonic: true