Skip to content

Commit

Permalink
lint fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
jvoravong committed Feb 27, 2025
1 parent e244a25 commit db21959
Show file tree
Hide file tree
Showing 5 changed files with 13 additions and 11 deletions.
8 changes: 4 additions & 4 deletions internal/components/components.go
Original file line number Diff line number Diff line change
Expand Up @@ -148,7 +148,7 @@ import (

func Get() (otelcol.Factories, error) {
var errs []error
extensions, err := extension.MakeFactoryMap(
extensions, err := otelcol.MakeFactoryMap[extension.Factory](
ackextension.NewFactory(),
basicauthextension.NewFactory(),
bearertokenauthextension.NewFactory(),
Expand All @@ -170,7 +170,7 @@ func Get() (otelcol.Factories, error) {
errs = append(errs, err)
}

receivers, err := receiver.MakeFactoryMap(
receivers, err := otelcol.MakeFactoryMap[receiver.Factory](
activedirectorydsreceiver.NewFactory(),
apachereceiver.NewFactory(),
apachesparkreceiver.NewFactory(),
Expand Down Expand Up @@ -244,7 +244,7 @@ func Get() (otelcol.Factories, error) {
errs = append(errs, err)
}

exporters, err := exporter.MakeFactoryMap(
exporters, err := otelcol.MakeFactoryMap[exporter.Factory](
awss3exporter.NewFactory(),
debugexporter.NewFactory(),
fileexporter.NewFactory(),
Expand All @@ -262,7 +262,7 @@ func Get() (otelcol.Factories, error) {
errs = append(errs, err)
}

processors, err := processor.MakeFactoryMap(
processors, err := otelcol.MakeFactoryMap[processor.Factory](
attributesprocessor.NewFactory(),
batchprocessor.NewFactory(),
cumulativetodeltaprocessor.NewFactory(),
Expand Down
3 changes: 2 additions & 1 deletion internal/receiver/discoveryreceiver/config_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@ package discoveryreceiver

import (
"fmt"
"go.opentelemetry.io/collector/confmap/xconfmap"
"path"
"testing"
"time"
Expand Down Expand Up @@ -139,7 +140,7 @@ func TestReceiverCreatorFactoryAndConfig(t *testing.T) {
require.NoError(t, err)
require.Equal(t, component.MustNewType("receiver_creator"), factory.Type())

require.NoError(t, component.ValidateConfig(rCfg))
require.NoError(t, xconfmap.Validate(rCfg))

creatorCfg, ok := rCfg.(*receivercreator.Config)
require.True(t, ok)
Expand Down
6 changes: 3 additions & 3 deletions internal/receiver/lightprometheusreceiver/scraper_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,7 @@ package lightprometheusreceiver
import (
"context"
"fmt"
"go.opentelemetry.io/collector/confmap/xconfmap"
"net/http"
"net/http/httptest"
"net/url"
Expand All @@ -26,7 +27,6 @@ import (

"github.com/open-telemetry/opentelemetry-collector-contrib/pkg/pdatatest/pmetrictest"
"github.com/stretchr/testify/require"
"go.opentelemetry.io/collector/component"
"go.opentelemetry.io/collector/component/componenttest"
"go.opentelemetry.io/collector/pdata/pmetric"
"go.opentelemetry.io/collector/receiver/receivertest"
Expand Down Expand Up @@ -85,9 +85,9 @@ func TestScraper(t *testing.T) {
t.Run(tt.name, func(t *testing.T) {
cfg := tt.cfg
cfg.ClientConfig.Endpoint = fmt.Sprintf("%s%s", promMock.URL, "/metrics")
require.NoError(t, component.ValidateConfig(cfg))
require.NoError(t, xconfmap.Validate(cfg))

scraper := newScraper(receivertest.NewNopSettings(), cfg)
scraper := newScraper(receivertest.NewNopSettingsWithType(receivertest.NopType), cfg)

err := scraper.start(context.Background(), componenttest.NewNopHost())
require.NoError(t, err)
Expand Down
3 changes: 2 additions & 1 deletion internal/receiver/scriptedinputsreceiver/operator.go
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,7 @@ package scriptedinputsreceiver
import (
"bufio"
"context"
"golang.org/x/text/encoding"
"io"
"sync"
"time"
Expand Down Expand Up @@ -44,7 +45,7 @@ type stdoutOperator struct {
logger *zap.SugaredLogger
cancelAll context.CancelFunc
splitFunc bufio.SplitFunc
decoder *decode.Decoder
decoder *encoding.Decoder
scriptContent string
helper.InputOperator
wg sync.WaitGroup
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@ package signalfxgatewayprometheusremotewritereceiver

import (
"context"
"go.opentelemetry.io/collector/receiver"
"testing"
"time"

Expand All @@ -24,7 +25,6 @@ import (
"go.opentelemetry.io/collector/component/componenttest"
"go.opentelemetry.io/collector/consumer/consumertest"
"go.opentelemetry.io/collector/otelcol"
"go.opentelemetry.io/collector/receiver"
"go.opentelemetry.io/collector/receiver/receivertest"

"github.com/signalfx/splunk-otel-collector/internal/receiver/signalfxgatewayprometheusremotewritereceiver/internal/metadata"
Expand Down Expand Up @@ -61,7 +61,7 @@ func TestNewFactory(t *testing.T) {
func TestFactoryOtelIntegration(t *testing.T) {
cfg := NewFactory().CreateDefaultConfig()
require.NotNil(t, cfg)
factory, err := receiver.MakeFactoryMap(NewFactory())
factory, err := otelcol.MakeFactoryMap[receiver.Factory]()
factories := otelcol.Factories{Receivers: factory}
require.NoError(t, err)
parsedFactory := factories.Receivers[metadata.Type]
Expand Down

0 comments on commit db21959

Please sign in to comment.