[chore]: fix staticcheck rules (processor) (#39196)

mmorel-35 · web-flow · commit 85b2b3d15b5a · 2025-04-08T06:50:42.000-07:00
#### Description

This fixes staticcheck issues in processor discovered after
golangci-lint@v2 upgrade

Signed-off-by: Matthieu MOREL &lt;matthieu.morel35@gmail.com&gt;
diff --git a/processor/attributesprocessor/attributes_log_test.go b/processor/attributesprocessor/attributes_log_test.go
@@ -76,7 +76,7 @@ func TestLogProcessor_NilEmptyData(t *testing.T) {
 	factory := NewFactory()
 	cfg := factory.CreateDefaultConfig()
 	oCfg := cfg.(*Config)
-	oCfg.Settings.Actions = []attraction.ActionKeyValue{
+	oCfg.Actions = []attraction.ActionKeyValue{
 		{Key: "attribute1", Action: attraction.INSERT, Value: 123},
 		{Key: "attribute1", Action: attraction.DELETE},
 	}
diff --git a/processor/attributesprocessor/attributes_metric_test.go b/processor/attributesprocessor/attributes_metric_test.go
@@ -84,7 +84,7 @@ func TestMetricProcessor_NilEmptyData(t *testing.T) {
 	factory := NewFactory()
 	cfg := factory.CreateDefaultConfig()
 	oCfg := cfg.(*Config)
-	oCfg.Settings.Actions = []attraction.ActionKeyValue{
+	oCfg.Actions = []attraction.ActionKeyValue{
 		{Key: "attribute1", Action: attraction.INSERT, Value: 123},
 		{Key: "attribute1", Action: attraction.DELETE},
 	}
diff --git a/processor/attributesprocessor/attributes_trace_test.go b/processor/attributesprocessor/attributes_trace_test.go
@@ -86,7 +86,7 @@ func TestSpanProcessor_NilEmptyData(t *testing.T) {
 	factory := NewFactory()
 	cfg := factory.CreateDefaultConfig()
 	oCfg := cfg.(*Config)
-	oCfg.Settings.Actions = []attraction.ActionKeyValue{
+	oCfg.Actions = []attraction.ActionKeyValue{
 		{Key: "attribute1", Action: attraction.INSERT, Value: 123},
 		{Key: "attribute1", Action: attraction.DELETE},
 	}
diff --git a/processor/coralogixprocessor/config.go b/processor/coralogixprocessor/config.go
@@ -19,10 +19,10 @@ type Config struct {
 }
 
 func (c *Config) Validate() error {
-	if c.databaseBlueprintsConfig.sampling.enabled && c.databaseBlueprintsConfig.sampling.maxCacheSizeMib <= 0 {
+	if c.sampling.enabled && c.sampling.maxCacheSizeMib <= 0 {
 		return fmt.Errorf("max_cache_size_mib must be a positive integer")
 	}
-	if c.databaseBlueprintsConfig.sampling.enabled && c.databaseBlueprintsConfig.sampling.maxCacheSizeMib != 0 {
+	if c.sampling.enabled && c.sampling.maxCacheSizeMib != 0 {
 		return fmt.Errorf("max_cache_size_mib can only be defined when sampling is enabled")
 	}
 	return nil
diff --git a/processor/deltatocumulativeprocessor/processor_test.go b/processor/deltatocumulativeprocessor/processor_test.go
@@ -173,7 +173,7 @@ func setupTestTelemetry() testTelemetry {
 
 func (tt *testTelemetry) newSettings() processor.Settings {
 	set := processortest.NewNopSettings(metadata.Type)
-	set.TelemetrySettings.MeterProvider = tt.meterProvider
+	set.MeterProvider = tt.meterProvider
 	return set
 }
 
diff --git a/processor/geoipprocessor/geoip_processor_test.go b/processor/geoipprocessor/geoip_processor_test.go
@@ -224,7 +224,7 @@ func TestProcessor(t *testing.T) {
 
 	for _, tt := range testCases {
 		t.Run(tt.name, func(t *testing.T) {
-			var attributes []attribute.Key = defaultAttributes
+			attributes := defaultAttributes
 			if tt.attributes != nil {
 				attributes = tt.attributes
 			}
diff --git a/processor/k8sattributesprocessor/internal/kube/client.go b/processor/k8sattributesprocessor/internal/kube/client.go
@@ -778,8 +778,8 @@ func (c *WatchClient) getIdentifiersFromAssoc(pod *Pod) []PodIdentifier {
 		skip := false
 		for i, source := range assoc.Sources {
 			// If association configured to take IP address from connection
-			switch {
-			case source.From == ConnectionSource:
+			switch source.From {
+			case ConnectionSource:
 				if pod.Address == "" {
 					skip = true
 					break
@@ -793,7 +793,7 @@ func (c *WatchClient) getIdentifiersFromAssoc(pod *Pod) []PodIdentifier {
 					break
 				}
 				ret[i] = PodIdentifierAttributeFromSource(source, pod.Address)
-			case source.From == ResourceSource:
+			case ResourceSource:
 				attr := ""
 				switch source.Name {
 				case conventions.AttributeK8SNamespaceName:
diff --git a/processor/k8sattributesprocessor/pod_association.go b/processor/k8sattributesprocessor/pod_association.go
@@ -29,14 +29,14 @@ func extractPodID(ctx context.Context, attrs pcommon.Map, associations []kube.As
 		ret := kube.PodIdentifier{}
 		for i, source := range asso.Sources {
 			// If association configured to take IP address from connection
-			switch {
-			case source.From == kube.ConnectionSource:
+			switch source.From {
+			case kube.ConnectionSource:
 				if connectionIP == "" {
 					skip = true
 					break
 				}
 				ret[i] = kube.PodIdentifierAttributeFromConnection(connectionIP)
-			case source.From == kube.ResourceSource:
+			case kube.ResourceSource:
 				// Extract values based on configured resource_attribute.
 				attributeValue := stringAttributeFromMap(attrs, source.Name)
 				if attributeValue == "" {
diff --git a/processor/logstransformprocessor/config.go b/processor/logstransformprocessor/config.go
@@ -20,7 +20,7 @@ var _ component.Config = (*Config)(nil)
 
 // Validate checks if the processor configuration is valid
 func (cfg *Config) Validate() error {
-	if len(cfg.BaseConfig.Operators) == 0 {
+	if len(cfg.Operators) == 0 {
 		return errors.New("no operators were configured for this logs transform processor")
 	}
 	return nil
diff --git a/processor/logstransformprocessor/factory.go b/processor/logstransformprocessor/factory.go
@@ -44,7 +44,7 @@ func createLogsProcessor(
 		return nil, errors.New("could not initialize logs transform processor")
 	}
 
-	if len(pCfg.BaseConfig.Operators) == 0 {
+	if len(pCfg.Operators) == 0 {
 		return nil, errors.New("no operators were configured for this logs transform processor")
 	}
 
diff --git a/processor/metricsgenerationprocessor/config.go b/processor/metricsgenerationprocessor/config.go
@@ -162,9 +162,10 @@ func (config *Config) Validate() error {
 			return fmt.Errorf("%q must be in %q", operationFieldName, operationTypeKeys())
 		}
 
-		if rule.Name == rule.Metric1 {
+		switch rule.Name {
+		case rule.Metric1:
 			return fmt.Errorf("value of field %q may not match value of field %q", nameFieldName, metric1FieldName)
-		} else if rule.Name == rule.Metric2 {
+		case rule.Metric2:
 			return fmt.Errorf("value of field %q may not match value of field %q", nameFieldName, metric2FieldName)
 		}
 	}
diff --git a/processor/metricstransformprocessor/factory.go b/processor/metricstransformprocessor/factory.go
@@ -154,9 +154,10 @@ func buildHelperConfig(config *Config, version string) ([]internalTransform, err
 			if len(op.ValueActions) > 0 {
 				mtpOp.valueActionsMapping = createLabelValueMapping(op.ValueActions, version)
 			}
-			if op.Action == aggregateLabels {
+			switch op.Action {
+			case aggregateLabels:
 				mtpOp.labelSetMap = sliceToSet(op.LabelSet)
-			} else if op.Action == aggregateLabelValues {
+			case aggregateLabelValues:
 				mtpOp.aggregatedValuesSet = sliceToSet(op.AggregatedValues)
 			}
 			helperT.Operations[j] = mtpOp
diff --git a/processor/probabilisticsamplerprocessor/tracesprocessor.go b/processor/probabilisticsamplerprocessor/tracesprocessor.go
@@ -90,7 +90,7 @@ func (tc *tracestateCarrier) clearThreshold() {
 
 func (tc *tracestateCarrier) reserialize() error {
 	var w strings.Builder
-	err := tc.W3CTraceState.Serialize(&w)
+	err := tc.Serialize(&w)
 	if err == nil {
 		tc.span.TraceState().FromRaw(w.String())
 	}
diff --git a/processor/remotetapprocessor/processor.go b/processor/remotetapprocessor/processor.go
@@ -50,11 +50,11 @@ func newProcessor(settings processor.Settings, config *Config) *wsprocessor {
 func (w *wsprocessor) Start(ctx context.Context, host component.Host) error {
 	var err error
 	var ln net.Listener
-	ln, err = w.config.ServerConfig.ToListener(ctx)
+	ln, err = w.config.ToListener(ctx)
 	if err != nil {
 		return fmt.Errorf("failed to bind to address %s: %w", w.config.Endpoint, err)
 	}
-	w.server, err = w.config.ServerConfig.ToServer(ctx, host, w.telemetrySettings, websocket.Server{Handler: w.handleConn})
+	w.server, err = w.config.ToServer(ctx, host, w.telemetrySettings, websocket.Server{Handler: w.handleConn})
 	if err != nil {
 		return err
 	}
diff --git a/processor/resourcedetectionprocessor/factory.go b/processor/resourcedetectionprocessor/factory.go
@@ -201,7 +201,7 @@ func (f *factory) getResourceDetectionProcessor(
 	if oCfg.Attributes != nil {
 		params.Logger.Warn("You are using deprecated `attributes` option that will be removed soon; use `resource_attributes` instead, details on configuration: https://github.com/open-telemetry/opentelemetry-collector-contrib/tree/main/processor/resourcedetectionprocessor#migration-from-attributes-to-resource_attributes")
 	}
-	provider, err := f.getResourceProvider(params, oCfg.ClientConfig.Timeout, oCfg.Detectors, oCfg.DetectorConfig, oCfg.Attributes)
+	provider, err := f.getResourceProvider(params, oCfg.Timeout, oCfg.Detectors, oCfg.DetectorConfig, oCfg.Attributes)
 	if err != nil {
 		return nil, err
 	}
diff --git a/processor/resourcedetectionprocessor/internal/k8snode/k8snode_test.go b/processor/resourcedetectionprocessor/internal/k8snode/k8snode_test.go
@@ -39,7 +39,7 @@ func TestDetect(t *testing.T) {
 	md.On("NodeName").Return("mainNode", nil)
 	cfg := CreateDefaultConfig()
 	// set k8s cluster env variables and auth type to create a dummy API client
-	cfg.APIConfig.AuthType = k8sconfig.AuthTypeNone
+	cfg.AuthType = k8sconfig.AuthTypeNone
 	t.Setenv("KUBERNETES_SERVICE_HOST", "127.0.0.1")
 	t.Setenv("KUBERNETES_SERVICE_PORT", "6443")
 	t.Setenv("K8S_NODE_NAME", "mainNode")
@@ -66,7 +66,7 @@ func TestDetectDisabledResourceAttributes(t *testing.T) {
 	cfg.ResourceAttributes.K8sNodeUID.Enabled = false
 	cfg.ResourceAttributes.K8sNodeName.Enabled = false
 	// set k8s cluster env variables and auth type to create a dummy API client
-	cfg.APIConfig.AuthType = k8sconfig.AuthTypeNone
+	cfg.AuthType = k8sconfig.AuthTypeNone
 	t.Setenv("KUBERNETES_SERVICE_HOST", "127.0.0.1")
 	t.Setenv("KUBERNETES_SERVICE_PORT", "6443")
 	t.Setenv("K8S_NODE_NAME", "mainNode")
diff --git a/processor/resourcedetectionprocessor/internal/kubeadm/kubeadm_test.go b/processor/resourcedetectionprocessor/internal/kubeadm/kubeadm_test.go
@@ -39,7 +39,7 @@ func TestDetect(t *testing.T) {
 	md.On("ClusterUID").Return("uid-1", nil)
 	cfg := CreateDefaultConfig()
 	// set k8s cluster env variables and auth type to create a dummy API client
-	cfg.APIConfig.AuthType = k8sconfig.AuthTypeNone
+	cfg.AuthType = k8sconfig.AuthTypeNone
 	t.Setenv("KUBERNETES_SERVICE_HOST", "127.0.0.1")
 	t.Setenv("KUBERNETES_SERVICE_PORT", "6443")
 
@@ -65,7 +65,7 @@ func TestDetectDisabledResourceAttributes(t *testing.T) {
 	cfg.ResourceAttributes.K8sClusterName.Enabled = false
 	cfg.ResourceAttributes.K8sClusterUID.Enabled = false
 	// set k8s cluster env variables and auth type to create a dummy API client
-	cfg.APIConfig.AuthType = k8sconfig.AuthTypeNone
+	cfg.AuthType = k8sconfig.AuthTypeNone
 	t.Setenv("KUBERNETES_SERVICE_HOST", "127.0.0.1")
 	t.Setenv("KUBERNETES_SERVICE_PORT", "6443")
 
diff --git a/processor/tailsamplingprocessor/internal/sampling/util.go b/processor/tailsamplingprocessor/internal/sampling/util.go
@@ -95,8 +95,8 @@ func invertHasInstrumentationLibrarySpanWithCondition(ilss ptrace.ScopeSpansSlic
 }
 
 func SetAttrOnScopeSpans(data *TraceData, attrName string, attrKey string) {
-	data.Mutex.Lock()
-	defer data.Mutex.Unlock()
+	data.Lock()
+	defer data.Unlock()
 
 	rs := data.ReceivedBatches.ResourceSpans()
 	for i := 0; i < rs.Len(); i++ {
diff --git a/processor/tailsamplingprocessor/processor_telemetry_test.go b/processor/tailsamplingprocessor/processor_telemetry_test.go
@@ -694,7 +694,7 @@ func setupTestTelemetry() testTelemetry {
 func (tt *testTelemetry) newSettings() processor.Settings {
 	set := processortest.NewNopSettings(metadata.Type)
 	set.ID = component.NewID(component.MustNewType("tail_sampling"))
-	set.TelemetrySettings.MeterProvider = tt.meterProvider
+	set.MeterProvider = tt.meterProvider
 	return set
 }
 
diff --git a/processor/transformprocessor/internal/common/logs.go b/processor/transformprocessor/internal/common/logs.go
@@ -38,7 +38,7 @@ func (l logStatements) ConsumeLogs(ctx context.Context, ld plog.Logs, cache *pco
 			logs := slogs.LogRecords()
 			for k := 0; k < logs.Len(); k++ {
 				tCtx := ottllog.NewTransformContext(logs.At(k), slogs.Scope(), rlogs.Resource(), slogs, rlogs, ottllog.WithCache(cache))
-				condition, err := l.BoolExpr.Eval(ctx, tCtx)
+				condition, err := l.Eval(ctx, tCtx)
 				if err != nil {
 					return err
 				}
diff --git a/processor/transformprocessor/internal/common/metrics.go b/processor/transformprocessor/internal/common/metrics.go
@@ -39,7 +39,7 @@ func (m metricStatements) ConsumeMetrics(ctx context.Context, md pmetric.Metrics
 			metrics := smetrics.Metrics()
 			for k := 0; k < metrics.Len(); k++ {
 				tCtx := ottlmetric.NewTransformContext(metrics.At(k), smetrics.Metrics(), smetrics.Scope(), rmetrics.Resource(), smetrics, rmetrics, ottlmetric.WithCache(cache))
-				condition, err := m.BoolExpr.Eval(ctx, tCtx)
+				condition, err := m.Eval(ctx, tCtx)
 				if err != nil {
 					return err
 				}
@@ -99,7 +99,7 @@ func (d dataPointStatements) ConsumeMetrics(ctx context.Context, md pmetric.Metr
 func (d dataPointStatements) handleNumberDataPoints(ctx context.Context, dps pmetric.NumberDataPointSlice, metric pmetric.Metric, metrics pmetric.MetricSlice, is pcommon.InstrumentationScope, resource pcommon.Resource, scopeMetrics pmetric.ScopeMetrics, resourceMetrics pmetric.ResourceMetrics, options []ottldatapoint.TransformContextOption) error {
 	for i := 0; i < dps.Len(); i++ {
 		tCtx := ottldatapoint.NewTransformContext(dps.At(i), metric, metrics, is, resource, scopeMetrics, resourceMetrics, options...)
-		condition, err := d.BoolExpr.Eval(ctx, tCtx)
+		condition, err := d.Eval(ctx, tCtx)
 		if err != nil {
 			return err
 		}
@@ -116,7 +116,7 @@ func (d dataPointStatements) handleNumberDataPoints(ctx context.Context, dps pme
 func (d dataPointStatements) handleHistogramDataPoints(ctx context.Context, dps pmetric.HistogramDataPointSlice, metric pmetric.Metric, metrics pmetric.MetricSlice, is pcommon.InstrumentationScope, resource pcommon.Resource, scopeMetrics pmetric.ScopeMetrics, resourceMetrics pmetric.ResourceMetrics, options []ottldatapoint.TransformContextOption) error {
 	for i := 0; i < dps.Len(); i++ {
 		tCtx := ottldatapoint.NewTransformContext(dps.At(i), metric, metrics, is, resource, scopeMetrics, resourceMetrics, options...)
-		condition, err := d.BoolExpr.Eval(ctx, tCtx)
+		condition, err := d.Eval(ctx, tCtx)
 		if err != nil {
 			return err
 		}
@@ -133,7 +133,7 @@ func (d dataPointStatements) handleHistogramDataPoints(ctx context.Context, dps
 func (d dataPointStatements) handleExponentialHistogramDataPoints(ctx context.Context, dps pmetric.ExponentialHistogramDataPointSlice, metric pmetric.Metric, metrics pmetric.MetricSlice, is pcommon.InstrumentationScope, resource pcommon.Resource, scopeMetrics pmetric.ScopeMetrics, resourceMetrics pmetric.ResourceMetrics, options []ottldatapoint.TransformContextOption) error {
 	for i := 0; i < dps.Len(); i++ {
 		tCtx := ottldatapoint.NewTransformContext(dps.At(i), metric, metrics, is, resource, scopeMetrics, resourceMetrics, options...)
-		condition, err := d.BoolExpr.Eval(ctx, tCtx)
+		condition, err := d.Eval(ctx, tCtx)
 		if err != nil {
 			return err
 		}
@@ -150,7 +150,7 @@ func (d dataPointStatements) handleExponentialHistogramDataPoints(ctx context.Co
 func (d dataPointStatements) handleSummaryDataPoints(ctx context.Context, dps pmetric.SummaryDataPointSlice, metric pmetric.Metric, metrics pmetric.MetricSlice, is pcommon.InstrumentationScope, resource pcommon.Resource, scopeMetrics pmetric.ScopeMetrics, resourceMetrics pmetric.ResourceMetrics, options []ottldatapoint.TransformContextOption) error {
 	for i := 0; i < dps.Len(); i++ {
 		tCtx := ottldatapoint.NewTransformContext(dps.At(i), metric, metrics, is, resource, scopeMetrics, resourceMetrics, options...)
-		condition, err := d.BoolExpr.Eval(ctx, tCtx)
+		condition, err := d.Eval(ctx, tCtx)
 		if err != nil {
 			return err
 		}
diff --git a/processor/transformprocessor/internal/common/processor.go b/processor/transformprocessor/internal/common/processor.go
@@ -34,7 +34,7 @@ func (r resourceStatements) ConsumeTraces(ctx context.Context, td ptrace.Traces,
 	for i := 0; i < td.ResourceSpans().Len(); i++ {
 		rspans := td.ResourceSpans().At(i)
 		tCtx := ottlresource.NewTransformContext(rspans.Resource(), rspans, ottlresource.WithCache(cache))
-		condition, err := r.BoolExpr.Eval(ctx, tCtx)
+		condition, err := r.Eval(ctx, tCtx)
 		if err != nil {
 			return err
 		}
@@ -52,7 +52,7 @@ func (r resourceStatements) ConsumeMetrics(ctx context.Context, md pmetric.Metri
 	for i := 0; i < md.ResourceMetrics().Len(); i++ {
 		rmetrics := md.ResourceMetrics().At(i)
 		tCtx := ottlresource.NewTransformContext(rmetrics.Resource(), rmetrics, ottlresource.WithCache(cache))
-		condition, err := r.BoolExpr.Eval(ctx, tCtx)
+		condition, err := r.Eval(ctx, tCtx)
 		if err != nil {
 			return err
 		}
@@ -70,7 +70,7 @@ func (r resourceStatements) ConsumeLogs(ctx context.Context, ld plog.Logs, cache
 	for i := 0; i < ld.ResourceLogs().Len(); i++ {
 		rlogs := ld.ResourceLogs().At(i)
 		tCtx := ottlresource.NewTransformContext(rlogs.Resource(), rlogs, ottlresource.WithCache(cache))
-		condition, err := r.BoolExpr.Eval(ctx, tCtx)
+		condition, err := r.Eval(ctx, tCtx)
 		if err != nil {
 			return err
 		}
@@ -101,7 +101,7 @@ func (s scopeStatements) ConsumeTraces(ctx context.Context, td ptrace.Traces, ca
 		for j := 0; j < rspans.ScopeSpans().Len(); j++ {
 			sspans := rspans.ScopeSpans().At(j)
 			tCtx := ottlscope.NewTransformContext(sspans.Scope(), rspans.Resource(), sspans, ottlscope.WithCache(cache))
-			condition, err := s.BoolExpr.Eval(ctx, tCtx)
+			condition, err := s.Eval(ctx, tCtx)
 			if err != nil {
 				return err
 			}
@@ -122,7 +122,7 @@ func (s scopeStatements) ConsumeMetrics(ctx context.Context, md pmetric.Metrics,
 		for j := 0; j < rmetrics.ScopeMetrics().Len(); j++ {
 			smetrics := rmetrics.ScopeMetrics().At(j)
 			tCtx := ottlscope.NewTransformContext(smetrics.Scope(), rmetrics.Resource(), smetrics, ottlscope.WithCache(cache))
-			condition, err := s.BoolExpr.Eval(ctx, tCtx)
+			condition, err := s.Eval(ctx, tCtx)
 			if err != nil {
 				return err
 			}
@@ -143,7 +143,7 @@ func (s scopeStatements) ConsumeLogs(ctx context.Context, ld plog.Logs, cache *p
 		for j := 0; j < rlogs.ScopeLogs().Len(); j++ {
 			slogs := rlogs.ScopeLogs().At(j)
 			tCtx := ottlscope.NewTransformContext(slogs.Scope(), rlogs.Resource(), slogs, ottlscope.WithCache(cache))
-			condition, err := s.BoolExpr.Eval(ctx, tCtx)
+			condition, err := s.Eval(ctx, tCtx)
 			if err != nil {
 				return err
 			}
diff --git a/processor/transformprocessor/internal/common/traces.go b/processor/transformprocessor/internal/common/traces.go
@@ -39,7 +39,7 @@ func (t traceStatements) ConsumeTraces(ctx context.Context, td ptrace.Traces, ca
 			spans := sspans.Spans()
 			for k := 0; k < spans.Len(); k++ {
 				tCtx := ottlspan.NewTransformContext(spans.At(k), sspans.Scope(), rspans.Resource(), sspans, rspans, ottlspan.WithCache(cache))
-				condition, err := t.BoolExpr.Eval(ctx, tCtx)
+				condition, err := t.Eval(ctx, tCtx)
 				if err != nil {
 					return err
 				}
@@ -75,7 +75,7 @@ func (s spanEventStatements) ConsumeTraces(ctx context.Context, td ptrace.Traces
 				spanEvents := span.Events()
 				for n := 0; n < spanEvents.Len(); n++ {
 					tCtx := ottlspanevent.NewTransformContext(spanEvents.At(n), span, sspans.Scope(), rspans.Resource(), sspans, rspans, ottlspanevent.WithCache(cache))
-					condition, err := s.BoolExpr.Eval(ctx, tCtx)
+					condition, err := s.Eval(ctx, tCtx)
 					if err != nil {
 						return err
 					}

Original file line number	Diff line number	Diff line change
`@@ -76,7 +76,7 @@ func TestLogProcessor_NilEmptyData(t *testing.T) {`
`76`	`76`	`factory := NewFactory()`
`77`	`77`	`cfg := factory.CreateDefaultConfig()`
`78`	`78`	`oCfg := cfg.(*Config)`
`79`		`- oCfg.Settings.Actions = []attraction.ActionKeyValue{`
	`79`	`+ oCfg.Actions = []attraction.ActionKeyValue{`
`80`	`80`	`{Key: "attribute1", Action: attraction.INSERT, Value: 123},`
`81`	`81`	`{Key: "attribute1", Action: attraction.DELETE},`
`82`	`82`	`}`
Original file line number	Diff line number	Diff line change
`@@ -84,7 +84,7 @@ func TestMetricProcessor_NilEmptyData(t *testing.T) {`
`84`	`84`	`factory := NewFactory()`
`85`	`85`	`cfg := factory.CreateDefaultConfig()`
`86`	`86`	`oCfg := cfg.(*Config)`
`87`		`- oCfg.Settings.Actions = []attraction.ActionKeyValue{`
	`87`	`+ oCfg.Actions = []attraction.ActionKeyValue{`
`88`	`88`	`{Key: "attribute1", Action: attraction.INSERT, Value: 123},`
`89`	`89`	`{Key: "attribute1", Action: attraction.DELETE},`
`90`	`90`	`}`
Original file line number	Diff line number	Diff line change
`@@ -86,7 +86,7 @@ func TestSpanProcessor_NilEmptyData(t *testing.T) {`
`86`	`86`	`factory := NewFactory()`
`87`	`87`	`cfg := factory.CreateDefaultConfig()`
`88`	`88`	`oCfg := cfg.(*Config)`
`89`		`- oCfg.Settings.Actions = []attraction.ActionKeyValue{`
	`89`	`+ oCfg.Actions = []attraction.ActionKeyValue{`
`90`	`90`	`{Key: "attribute1", Action: attraction.INSERT, Value: 123},`
`91`	`91`	`{Key: "attribute1", Action: attraction.DELETE},`
`92`	`92`	`}`
Original file line number	Diff line number	Diff line change
`@@ -19,10 +19,10 @@ type Config struct {`
`19`	`19`	`}`
`20`	`20`
`21`	`21`	`func (c *Config) Validate() error {`
`22`		`- if c.databaseBlueprintsConfig.sampling.enabled && c.databaseBlueprintsConfig.sampling.maxCacheSizeMib <= 0 {`
	`22`	`+ if c.sampling.enabled && c.sampling.maxCacheSizeMib <= 0 {`
`23`	`23`	`return fmt.Errorf("max_cache_size_mib must be a positive integer")`
`24`	`24`	`}`
`25`		`- if c.databaseBlueprintsConfig.sampling.enabled && c.databaseBlueprintsConfig.sampling.maxCacheSizeMib != 0 {`
	`25`	`+ if c.sampling.enabled && c.sampling.maxCacheSizeMib != 0 {`
`26`	`26`	`return fmt.Errorf("max_cache_size_mib can only be defined when sampling is enabled")`
`27`	`27`	`}`
`28`	`28`	`return nil`
Original file line number	Diff line number	Diff line change
`@@ -173,7 +173,7 @@ func setupTestTelemetry() testTelemetry {`
`173`	`173`
`174`	`174`	`func (tt *testTelemetry) newSettings() processor.Settings {`
`175`	`175`	`set := processortest.NewNopSettings(metadata.Type)`
`176`		`- set.TelemetrySettings.MeterProvider = tt.meterProvider`
	`176`	`+ set.MeterProvider = tt.meterProvider`
`177`	`177`	`return set`
`178`	`178`	`}`
`179`	`179`
Original file line number	Diff line number	Diff line change
`@@ -224,7 +224,7 @@ func TestProcessor(t *testing.T) {`
`224`	`224`
`225`	`225`	`for _, tt := range testCases {`
`226`	`226`	`t.Run(tt.name, func(t *testing.T) {`
`227`		`- var attributes []attribute.Key = defaultAttributes`
	`227`	`+ attributes := defaultAttributes`
`228`	`228`	`if tt.attributes != nil {`
`229`	`229`	`attributes = tt.attributes`
`230`	`230`	`}`
Original file line number	Diff line number	Diff line change
`@@ -20,7 +20,7 @@ var _ component.Config = (*Config)(nil)`
`20`	`20`
`21`	`21`	`// Validate checks if the processor configuration is valid`
`22`	`22`	`func (cfg *Config) Validate() error {`
`23`		`- if len(cfg.BaseConfig.Operators) == 0 {`
	`23`	`+ if len(cfg.Operators) == 0 {`
`24`	`24`	`return errors.New("no operators were configured for this logs transform processor")`
`25`	`25`	`}`
`26`	`26`	`return nil`
Original file line number	Diff line number	Diff line change
`@@ -44,7 +44,7 @@ func createLogsProcessor(`
`44`	`44`	`return nil, errors.New("could not initialize logs transform processor")`
`45`	`45`	`}`
`46`	`46`
`47`		`- if len(pCfg.BaseConfig.Operators) == 0 {`
	`47`	`+ if len(pCfg.Operators) == 0 {`
`48`	`48`	`return nil, errors.New("no operators were configured for this logs transform processor")`
`49`	`49`	`}`
`50`	`50`