Merge branch 'main' into balance-metrics-by-resources

connector/failoverconnector/internal/state/pipeline_selector.go

@@ -108,7 +108,7 @@ func (p *PipelineSelector) retryHighPriorityPipelines(ctx context.Context, retry
 	}
 }
 
-// checkStopRetry checks if retry should be suspended if all higher priority levels have exceeded their max retries
+// checkContinueRetry checks if retry should be suspended if all higher priority levels have exceeded their max retries
 func (p *PipelineSelector) checkContinueRetry(index int) bool {
 	for i := 0; i < index; i++ {
 		if p.loadRetryCount(i) < p.constants.MaxRetries {

exporter/splunkhecexporter/client_test.go

@@ -2095,7 +2095,7 @@ func TestPushLogsRetryableFailureMultipleResources(t *testing.T) {
 	assert.Equal(t, logs, expectedErr.Data())
 }
 
-// validateCompressedEqual validates that GZipped `got` contains `expected` strings
+// validateCompressedContains validates that GZipped `got` contains `expected` strings
 func validateCompressedContains(t *testing.T, expected []string, got []byte) {
 	z, err := gzip.NewReader(bytes.NewReader(got))
 	require.NoError(t, err)

exporter/sumologicexporter/prometheus_formatter.go

@@ -138,7 +138,7 @@ func (f *prometheusFormatter) sanitizeKeyBytes(s []byte) []byte {
 	return f.sanitNameRegex.ReplaceAll(s, []byte{'_'})
 }
 
-// sanitizeKey returns sanitized value string performing the following substitutions:
+// sanitizeValue returns sanitized value string performing the following substitutions:
 // `/` -> `//`
 // `"` -> `\"`
 // "\n" -> `\n`