Adds Profiles Signal

Makefile

@@ -160,7 +160,7 @@ OPENTELEMETRY_PROTO_SRC_DIR=pdata/internal/opentelemetry-proto
 OPENTELEMETRY_PROTO_VERSION=v1.2.0
 
 # Find all .proto files.
-OPENTELEMETRY_PROTO_FILES := $(subst $(OPENTELEMETRY_PROTO_SRC_DIR)/,,$(wildcard $(OPENTELEMETRY_PROTO_SRC_DIR)/opentelemetry/proto/*/v1/*.proto $(OPENTELEMETRY_PROTO_SRC_DIR)/opentelemetry/proto/collector/*/v1/*.proto))
+OPENTELEMETRY_PROTO_FILES := $(subst $(OPENTELEMETRY_PROTO_SRC_DIR)/,,$(wildcard $(OPENTELEMETRY_PROTO_SRC_DIR)/opentelemetry/proto/*/v1/*.proto $(OPENTELEMETRY_PROTO_SRC_DIR)/opentelemetry/proto/collector/*/v1/*.proto $(OPENTELEMETRY_PROTO_SRC_DIR)/opentelemetry/proto/*/v1experimental/*.proto $(OPENTELEMETRY_PROTO_SRC_DIR)/opentelemetry/proto/collector/*/v1experimental/*.proto))
 
 # Target directory to write generated files to.
 PROTO_TARGET_GEN_DIR=pdata/internal/data/protogen
@@ -206,6 +206,8 @@ genproto_sub:
 	# HACK: Workaround for istio 1.15 / envoy 1.23.1 mistakenly emitting deprecated field.
 	# reserved 1000 -> repeated ScopeLogs deprecated_scope_logs = 1000;
 	sed 's/reserved 1000;/repeated ScopeLogs deprecated_scope_logs = 1000;/g' $(PROTO_INTERMEDIATE_DIR)/opentelemetry/proto/logs/v1/logs.proto 1<> $(PROTO_INTERMEDIATE_DIR)/opentelemetry/proto/logs/v1/logs.proto
+	# reserved 1000 -> repeated ScopeProfiles deprecated_scope_profiles = 1000;
+	sed 's/reserved 1000;/repeated ScopeProfiles deprecated_scope_profiles = 1000;/g' $(PROTO_INTERMEDIATE_DIR)/opentelemetry/proto/profiles/v1experimental/profiles.proto 1<> $(PROTO_INTERMEDIATE_DIR)/opentelemetry/proto/profiles/v1experimental/profiles.proto
 	# reserved 1000 -> repeated ScopeMetrics deprecated_scope_metrics = 1000;
 	sed 's/reserved 1000;/repeated ScopeMetrics deprecated_scope_metrics = 1000;/g' $(PROTO_INTERMEDIATE_DIR)/opentelemetry/proto/metrics/v1/metrics.proto 1<> $(PROTO_INTERMEDIATE_DIR)/opentelemetry/proto/metrics/v1/metrics.proto
 	# reserved 1000 -> repeated ScopeSpans deprecated_scope_spans = 1000;

component/componenttest/obsreporttest.go

@@ -66,6 +66,10 @@ func (tts *TestTelemetry) CheckExporterEnqueueFailedLogs(enqueueFailed int64) er
 	return tts.prometheusChecker.checkExporterEnqueueFailed(tts.id, "log_records", enqueueFailed)
 }
 
+func (tts *TestTelemetry) CheckExporterEnqueueFailedProfiles(enqueueFailed int64) error {
+	return tts.prometheusChecker.checkExporterEnqueueFailed(tts.id, "profiles", enqueueFailed)
+}
+
 // CheckExporterLogs checks that for the current exported values for logs exporter metrics match given values.
 // When this function is called it is required to also call SetupTelemetry as first thing.
 func (tts *TestTelemetry) CheckExporterLogs(sentLogRecords, sendFailedLogRecords int64) error {
@@ -76,6 +80,12 @@ func (tts *TestTelemetry) CheckExporterMetricGauge(metric string, val int64) err
 	return tts.prometheusChecker.checkExporterMetricGauge(tts.id, metric, val)
 }
 
+// CheckExporterProfiles checks that for the current exported values for profiles exporter metrics match given values.
+// When this function is called it is required to also call SetupTelemetry as first thing.
+func (tts *TestTelemetry) CheckExporterProfiles(sentProfiles, sendFailedProfiles int64) error {
+	return tts.prometheusChecker.checkExporterProfiles(tts.id, sentProfiles, sendFailedProfiles)
+}
+
 // CheckProcessorTraces checks that for the current exported values for trace exporter metrics match given values.
 // When this function is called it is required to also call SetupTelemetry as first thing.
 func (tts *TestTelemetry) CheckProcessorTraces(acceptedSpans, refusedSpans, droppedSpans int64) error {
@@ -94,6 +104,12 @@ func (tts *TestTelemetry) CheckProcessorLogs(acceptedLogRecords, refusedLogRecor
 	return tts.prometheusChecker.checkProcessorLogs(tts.id, acceptedLogRecords, refusedLogRecords, droppedLogRecords)
 }
 
+// CheckProcessorProfiles checks that for the current exported values for profiles exporter metrics match given values.
+// When this function is called it is required to also call SetupTelemetry as first thing.
+func (tts *TestTelemetry) CheckProcessorProfiles(acceptedProfiles, refusedProfiles, droppedProfiles int64) error {
+	return tts.prometheusChecker.checkProcessorProfiles(tts.id, acceptedProfiles, refusedProfiles, droppedProfiles)
+}
+
 // CheckReceiverTraces checks that for the current exported values for trace receiver metrics match given values.
 // When this function is called it is required to also call SetupTelemetry as first thing.
 func (tts *TestTelemetry) CheckReceiverTraces(protocol string, acceptedSpans, droppedSpans int64) error {
@@ -106,6 +122,12 @@ func (tts *TestTelemetry) CheckReceiverLogs(protocol string, acceptedLogRecords,
 	return tts.prometheusChecker.checkReceiverLogs(tts.id, protocol, acceptedLogRecords, droppedLogRecords)
 }
 
+// CheckReceiverProfiles checks that for the current exported values for profiles receiver metrics match given values.
+// When this function is called it is required to also call SetupTelemetry as first thing.
+func (tts *TestTelemetry) CheckReceiverProfiles(protocol string, acceptedProfiles, droppedProfiles int64) error {
+	return tts.prometheusChecker.checkReceiverProfiles(tts.id, protocol, acceptedProfiles, droppedProfiles)
+}
+
 // CheckReceiverMetrics checks that for the current exported values for metrics receiver metrics match given values.
 // When this function is called it is required to also call SetupTelemetry as first thing.
 func (tts *TestTelemetry) CheckReceiverMetrics(protocol string, acceptedMetricPoints, droppedMetricPoints int64) error {

component/componenttest/otelprometheuschecker.go

@@ -41,6 +41,10 @@ func (pc *prometheusChecker) checkReceiverMetrics(receiver component.ID, protoco
 	return pc.checkReceiver(receiver, "metric_points", protocol, accepted, dropped)
 }
 
+func (pc *prometheusChecker) checkReceiverProfiles(receiver component.ID, protocol string, accepted, dropped int64) error {
+	return pc.checkReceiver(receiver, "profiles", protocol, accepted, dropped)
+}
+
 func (pc *prometheusChecker) checkReceiver(receiver component.ID, datatype, protocol string, acceptedMetricPoints, droppedMetricPoints int64) error {
 	receiverAttrs := attributesForReceiverMetrics(receiver, protocol)
 	return multierr.Combine(
@@ -60,6 +64,10 @@ func (pc *prometheusChecker) checkProcessorLogs(processor component.ID, accepted
 	return pc.checkProcessor(processor, "log_records", accepted, refused, dropped)
 }
 
+func (pc *prometheusChecker) checkProcessorProfiles(processor component.ID, accepted, refused, dropped int64) error {
+	return pc.checkProcessor(processor, "profiles", accepted, refused, dropped)
+}
+
 func (pc *prometheusChecker) checkProcessor(processor component.ID, datatype string, accepted, refused, dropped int64) error {
 	processorAttrs := attributesForProcessorMetrics(processor)
 	return multierr.Combine(
@@ -80,6 +88,10 @@ func (pc *prometheusChecker) checkExporterMetrics(exporter component.ID, sent, s
 	return pc.checkExporter(exporter, "metric_points", sent, sendFailed)
 }
 
+func (pc *prometheusChecker) checkExporterProfiles(exporter component.ID, sent, sendFailed int64) error {
+	return pc.checkExporter(exporter, "profiles", sent, sendFailed)
+}
+
 func (pc *prometheusChecker) checkExporter(exporter component.ID, datatype string, sent, sendFailed int64) error {
 	exporterAttrs := attributesForExporterMetrics(exporter)
 	errs := pc.checkCounter(fmt.Sprintf("exporter_sent_%s", datatype), sent, exporterAttrs)

component/componenttest/testdata/prometheus_response

@@ -16,6 +16,12 @@ exporter_send_failed_log_records{exporter="fakeExporter"} 36
 # HELP exporter_sent_log_records Number of logs successfully sent to destination.
 # TYPE exporter_sent_log_records counter
 exporter_sent_log_records{exporter="fakeExporter"} 103
+# HELP exporter_send_failed_profiles Number of logs in failed attempts to send to destination.
+# TYPE exporter_send_failed_profiles counter
+exporter_send_failed_profiles{exporter="fakeExporter"} 32
+# HELP exporter_sent_profiles Number of logs successfully sent to destination.
+# TYPE exporter_sent_profiles counter
+exporter_sent_profiles{exporter="fakeExporter"} 106
 # HELP processor_accepted_spans Number of spans successfully pushed into the next component in the pipeline.
 # TYPE processor_accepted_spans counter
 processor_accepted_spans{processor="fakeProcessor"} 42
@@ -46,6 +52,18 @@ processor_dropped_log_records{processor="fakeProcessor"} 14
 # HELP receiver_accepted_log_records Number of log records successfully pushed into the pipeline.
 # TYPE receiver_accepted_log_records counter
 receiver_accepted_log_records{receiver="fakeReceiver",transport="fakeTransport"} 102
+# HELP processor_accepted_profiles Number of log records successfully pushed into the next component in the pipeline.
+# TYPE processor_accepted_profiles counter
+processor_accepted_profiles{processor="fakeProcessor"} 102
+# HELP processor_refused_profiles Number of log records that were rejected by the next component in the pipeline.
+# TYPE processor_refused_profiles counter
+processor_refused_profiles{processor="fakeProcessor"} 35
+# HELP processor_dropped_profiles Number of log records that were dropped.
+# TYPE processor_dropped_profiles counter
+processor_dropped_profiles{processor="fakeProcessor"} 14
+# HELP receiver_accepted_profiles Number of log records successfully pushed into the pipeline.
+# TYPE receiver_accepted_profiles counter
+receiver_accepted_profiles{receiver="fakeReceiver",transport="fakeTransport"} 102
 # HELP receiver_accepted_metric_points Number of metric points successfully pushed into the pipeline.
 # TYPE receiver_accepted_metric_points counter
 receiver_accepted_metric_points{receiver="fakeReceiver",transport="fakeTransport"} 7
@@ -55,6 +73,9 @@ receiver_accepted_spans{receiver="fakeReceiver",transport="fakeTransport"} 42
 # HELP receiver_refused_log_records Number of log records that could not be pushed into the pipeline.
 # TYPE receiver_refused_log_records counter
 receiver_refused_log_records{receiver="fakeReceiver",transport="fakeTransport"} 35
+# HELP receiver_refused_profiles Number of log records that could not be pushed into the pipeline.
+# TYPE receiver_refused_profiles counter
+receiver_refused_profiles{receiver="fakeReceiver",transport="fakeTransport"} 35
 # HELP receiver_refused_metric_points Number of metric points that could not be pushed into the pipeline.
 # TYPE receiver_refused_metric_points counter
 receiver_refused_metric_points{receiver="fakeReceiver",transport="fakeTransport"} 41

component/config.go

@@ -176,4 +176,7 @@ var (
 
 	// DataTypeLogs is the data type tag for logs.
 	DataTypeLogs = mustNewDataType("logs")
+
+	// DataTypeProfiles is the data type tag for profiles.
+	DataTypeProfiles = mustNewDataType("profiles")
 )