Skip to content

Commit

Permalink
chore: fix function names in comment (open-telemetry#10027)
Browse files Browse the repository at this point in the history
fix function names in comment


Signed-off-by: dockercui <[email protected]>
Co-authored-by: Alex Boten <[email protected]>
  • Loading branch information
dockercui and codeboten authored Apr 26, 2024
1 parent 326ef7c commit 6dfa6bc
Show file tree
Hide file tree
Showing 4 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion component/componenttest/otelprometheuschecker.go
Original file line number Diff line number Diff line change
Expand Up @@ -196,7 +196,7 @@ func attributesForProcessorMetrics(processor component.ID) []attribute.KeyValue
return []attribute.KeyValue{attribute.String(processorTag, processor.String())}
}

// attributesForReceiverMetrics returns the attributes that are needed for the receiver metrics.
// attributesForExporterMetrics returns the attributes that are needed for the receiver metrics.
func attributesForExporterMetrics(exporter component.ID) []attribute.KeyValue {
return []attribute.KeyValue{attribute.String(exporterTag, exporter.String())}
}
2 changes: 1 addition & 1 deletion otelcol/collector.go
Original file line number Diff line number Diff line change
Expand Up @@ -322,7 +322,7 @@ func (col *Collector) setCollectorState(state State) {
col.state.Store(int32(state))
}

// validatePipelineConfig validates that the components in a pipeline support the
// validatePipelineCfg validates that the components in a pipeline support the
// signal type of the pipeline. For example, this function will return an error if
// a metrics pipeline has non-metrics components.
func (col *Collector) validatePipelineCfg(ctx context.Context, cfg *Config, factories Factories) error {
Expand Down
2 changes: 1 addition & 1 deletion receiver/otlpreceiver/otlp_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -594,7 +594,7 @@ func TestOTLPReceiverGRPCTracesIngestTest(t *testing.T) {
require.NoError(t, tt.CheckReceiverTraces("grpc", int64(expectedReceivedBatches), int64(expectedIngestionBlockedRPCs)))
}

// TestOTLPReceiverHTTPTracesNextConsumerResponse checks that the HTTP trace receiver
// TestOTLPReceiverHTTPTracesIngestTest checks that the HTTP trace receiver
// is returning the proper response (return and metrics) when the next consumer
// in the pipeline reports error. The test changes the responses returned by the
// next trace consumer, checks if data was passed down the pipeline and if
Expand Down
2 changes: 1 addition & 1 deletion receiver/receivertest/contract_checker.go
Original file line number Diff line number Diff line change
Expand Up @@ -390,7 +390,7 @@ func (m *mockConsumer) ConsumeMetrics(_ context.Context, data pmetric.Metrics) e
return m.consume(ids)
}

// idSetFromLogs computes an idSet from given pmetric.Metrics. The idSet will contain ids of all metric data points.
// idSetFromMetrics computes an idSet from given pmetric.Metrics. The idSet will contain ids of all metric data points.
func idSetFromMetrics(data pmetric.Metrics) (idSet, error) {
ds := map[UniqueIDAttrVal]bool{}
rss := data.ResourceMetrics()
Expand Down

0 comments on commit 6dfa6bc

Please sign in to comment.