diff --git a/connector/spanmetricsconnector/connector_test.go b/connector/spanmetricsconnector/connector_test.go index 537a69d6e3711..f4473d290bb6d 100644 --- a/connector/spanmetricsconnector/connector_test.go +++ b/connector/spanmetricsconnector/connector_test.go @@ -80,7 +80,7 @@ func verifyConsumeMetricsInputCumulative(t testing.TB, input pmetric.Metrics) bo return verifyConsumeMetricsInput(t, input, pmetric.AggregationTemporalityCumulative, 1) } -func verifyBadMetricsOkay(t testing.TB, input pmetric.Metrics) bool { +func verifyBadMetricsOkay(_ testing.TB, _ pmetric.Metrics) bool { return true // Validating no exception } diff --git a/exporter/alibabacloudlogserviceexporter/logs_exporter.go b/exporter/alibabacloudlogserviceexporter/logs_exporter.go index ac071236eba11..f096700e2a6e4 100644 --- a/exporter/alibabacloudlogserviceexporter/logs_exporter.go +++ b/exporter/alibabacloudlogserviceexporter/logs_exporter.go @@ -38,7 +38,7 @@ type logServiceLogsSender struct { } func (s *logServiceLogsSender) pushLogsData( - ctx context.Context, + _ context.Context, md plog.Logs) error { var err error slsLogs := logDataToLogService(md) diff --git a/exporter/logzioexporter/logger.go b/exporter/logzioexporter/logger.go index 41e14e69b1fa8..3f4bacbf1a65b 100644 --- a/exporter/logzioexporter/logger.go +++ b/exporter/logzioexporter/logger.go @@ -20,7 +20,7 @@ type hclog2ZapLogger struct { name string } -func (l *hclog2ZapLogger) Log(level hclog.Level, msg string, args ...interface{}) {} +func (l *hclog2ZapLogger) Log(_ hclog.Level, _ string, _ ...interface{}) {} func (l *hclog2ZapLogger) ImpliedArgs() []interface{} { return nil @@ -30,12 +30,12 @@ func (l *hclog2ZapLogger) Name() string { return l.name } -func (l *hclog2ZapLogger) StandardWriter(opts *hclog.StandardLoggerOptions) io.Writer { +func (l *hclog2ZapLogger) StandardWriter(_ *hclog.StandardLoggerOptions) io.Writer { return nil } // Trace implementation. -func (l *hclog2ZapLogger) Trace(msg string, args ...interface{}) {} +func (l *hclog2ZapLogger) Trace(_ string, _ ...interface{}) {} // Debug implementation. func (l *hclog2ZapLogger) Debug(msg string, args ...interface{}) { @@ -83,13 +83,13 @@ func (l *hclog2ZapLogger) Named(name string) hclog.Logger { } // ResetNamed implementation. -func (l *hclog2ZapLogger) ResetNamed(name string) hclog.Logger { +func (l *hclog2ZapLogger) ResetNamed(_ string) hclog.Logger { // no need to implement that as go-plugin doesn't use this method. return &hclog2ZapLogger{} } // SetLevel implementation. -func (l *hclog2ZapLogger) SetLevel(level hclog.Level) { +func (l *hclog2ZapLogger) SetLevel(_ hclog.Level) { // no need to implement that as go-plugin doesn't use this method. } @@ -100,7 +100,7 @@ func (l *hclog2ZapLogger) GetLevel() hclog.Level { } // StandardLogger implementation. -func (l *hclog2ZapLogger) StandardLogger(opts *hclog.StandardLoggerOptions) *log.Logger { +func (l *hclog2ZapLogger) StandardLogger(_ *hclog.StandardLoggerOptions) *log.Logger { // no need to implement that as go-plugin doesn't use this method. return log.New(io.Discard, "", 0) } diff --git a/internal/aws/awsutil/conn_test.go b/internal/aws/awsutil/conn_test.go index 80e4d4012f9d2..6009c4a39d1f7 100644 --- a/internal/aws/awsutil/conn_test.go +++ b/internal/aws/awsutil/conn_test.go @@ -21,7 +21,7 @@ type mockConn struct { sn *session.Session } -func (c *mockConn) getEC2Region(s *session.Session) (string, error) { +func (c *mockConn) getEC2Region(_ *session.Session) (string, error) { args := c.Called(nil) errorStr := args.String(0) var err error @@ -32,7 +32,7 @@ func (c *mockConn) getEC2Region(s *session.Session) (string, error) { return ec2Region, nil } -func (c *mockConn) newAWSSession(logger *zap.Logger, roleArn string, region string) (*session.Session, error) { +func (c *mockConn) newAWSSession(_ *zap.Logger, _ string, _ string) (*session.Session, error) { return c.sn, nil } diff --git a/internal/aws/proxy/conn_test.go b/internal/aws/proxy/conn_test.go index 7496e26676f27..a8e3401d86718 100644 --- a/internal/aws/proxy/conn_test.go +++ b/internal/aws/proxy/conn_test.go @@ -26,14 +26,14 @@ type mock struct { sn *session.Session } -func (m *mock) getEC2Region(s *session.Session) (string, error) { +func (m *mock) getEC2Region(_ *session.Session) (string, error) { if m.getEC2RegionErr != nil { return "", m.getEC2RegionErr } return ec2Region, nil } -func (m *mock) newAWSSession(roleArn string, region string, logger *zap.Logger) (*session.Session, error) { +func (m *mock) newAWSSession(_ string, _ string, _ *zap.Logger) (*session.Session, error) { return m.sn, nil } diff --git a/pkg/ottl/contexts/ottlscope/scope.go b/pkg/ottl/contexts/ottlscope/scope.go index 5dddffc41dc09..a7c121b289a41 100644 --- a/pkg/ottl/contexts/ottlscope/scope.go +++ b/pkg/ottl/contexts/ottlscope/scope.go @@ -77,7 +77,7 @@ func NewStatements(statements []*ottl.Statement[TransformContext], telemetrySett return s } -func parseEnum(val *ottl.EnumSymbol) (*ottl.Enum, error) { +func parseEnum(_ *ottl.EnumSymbol) (*ottl.Enum, error) { return nil, fmt.Errorf("instrumentation scope context does not provide Enum support") } diff --git a/receiver/k8seventsreceiver/receiver.go b/receiver/k8seventsreceiver/receiver.go index ed261029ae382..180e5139789dd 100644 --- a/receiver/k8seventsreceiver/receiver.go +++ b/receiver/k8seventsreceiver/receiver.go @@ -59,7 +59,7 @@ func newReceiver( }, nil } -func (kr *k8seventsReceiver) Start(ctx context.Context, host component.Host) error { +func (kr *k8seventsReceiver) Start(ctx context.Context, _ component.Host) error { kr.ctx, kr.cancel = context.WithCancel(ctx) kr.settings.Logger.Info("starting to watch namespaces for the events.") diff --git a/receiver/k8sobjectsreceiver/receiver.go b/receiver/k8sobjectsreceiver/receiver.go index 3ae6ccaf56f0f..48ef7cf36cf78 100644 --- a/receiver/k8sobjectsreceiver/receiver.go +++ b/receiver/k8sobjectsreceiver/receiver.go @@ -58,7 +58,7 @@ func newReceiver(params receiver.CreateSettings, config *Config, consumer consum }, nil } -func (kr *k8sobjectsreceiver) Start(ctx context.Context, host component.Host) error { +func (kr *k8sobjectsreceiver) Start(ctx context.Context, _ component.Host) error { kr.setting.Logger.Info("Object Receiver started") for _, object := range kr.objects { diff --git a/receiver/mongodbatlasreceiver/access_logs.go b/receiver/mongodbatlasreceiver/access_logs.go index 855d62598892a..914667e97b703 100644 --- a/receiver/mongodbatlasreceiver/access_logs.go +++ b/receiver/mongodbatlasreceiver/access_logs.go @@ -83,7 +83,7 @@ func newAccessLogsReceiver(settings rcvr.CreateSettings, cfg *Config, consumer c return r } -func (alr *accessLogsReceiver) Start(ctx context.Context, host component.Host, storageClient storage.Client) error { +func (alr *accessLogsReceiver) Start(ctx context.Context, _ component.Host, storageClient storage.Client) error { alr.logger.Debug("Starting up access log receiver") cancelCtx, cancel := context.WithCancel(ctx) alr.cancel = cancel @@ -92,7 +92,7 @@ func (alr *accessLogsReceiver) Start(ctx context.Context, host component.Host, s return alr.startPolling(cancelCtx) } -func (alr *accessLogsReceiver) Shutdown(ctx context.Context) error { +func (alr *accessLogsReceiver) Shutdown(_ context.Context) error { alr.logger.Debug("Shutting down accessLog receiver") alr.cancel() alr.wg.Wait() diff --git a/receiver/mongodbatlasreceiver/events.go b/receiver/mongodbatlasreceiver/events.go index 29507d479bf89..cd56f767d4011 100644 --- a/receiver/mongodbatlasreceiver/events.go +++ b/receiver/mongodbatlasreceiver/events.go @@ -83,7 +83,7 @@ func newEventsReceiver(settings rcvr.CreateSettings, c *Config, consumer consume return r } -func (er *eventsReceiver) Start(ctx context.Context, host component.Host, storageClient storage.Client) error { +func (er *eventsReceiver) Start(ctx context.Context, _ component.Host, storageClient storage.Client) error { er.logger.Debug("Starting up events receiver") cancelCtx, cancel := context.WithCancel(ctx) er.cancel = cancel diff --git a/receiver/mongodbatlasreceiver/factory.go b/receiver/mongodbatlasreceiver/factory.go index 0e0463865d628..0d1ff855fee88 100644 --- a/receiver/mongodbatlasreceiver/factory.go +++ b/receiver/mongodbatlasreceiver/factory.go @@ -51,7 +51,7 @@ func createMetricsReceiver( } func createCombinedLogReceiver( - ctx context.Context, + _ context.Context, params rcvr.CreateSettings, rConf component.Config, consumer consumer.Logs, diff --git a/receiver/mongodbatlasreceiver/internal/metadata/metric_name_mapping.go b/receiver/mongodbatlasreceiver/internal/metadata/metric_name_mapping.go index f3afbd81d71bf..e8793b609b3ce 100644 --- a/receiver/mongodbatlasreceiver/internal/metadata/metric_name_mapping.go +++ b/receiver/mongodbatlasreceiver/internal/metadata/metric_name_mapping.go @@ -849,7 +849,7 @@ func getRecordFunc(metricName string) metricRecordFunc { } } -func MeasurementsToMetric(mb *MetricsBuilder, meas *mongodbatlas.Measurements, buildUnrecognized bool) error { +func MeasurementsToMetric(mb *MetricsBuilder, meas *mongodbatlas.Measurements, _ bool) error { recordFunc := getRecordFunc(meas.Name) if recordFunc == nil { return nil diff --git a/receiver/mongodbatlasreceiver/logs.go b/receiver/mongodbatlasreceiver/logs.go index cac6834085fb4..da2e41e03d0cb 100644 --- a/receiver/mongodbatlasreceiver/logs.go +++ b/receiver/mongodbatlasreceiver/logs.go @@ -60,7 +60,7 @@ func newMongoDBAtlasLogsReceiver(settings rcvr.CreateSettings, cfg *Config, cons } // Log receiver logic -func (s *logsReceiver) Start(ctx context.Context, host component.Host) error { +func (s *logsReceiver) Start(ctx context.Context, _ component.Host) error { s.wg.Add(1) go func() { defer s.wg.Done() @@ -83,7 +83,7 @@ func (s *logsReceiver) Start(ctx context.Context, host component.Host) error { return nil } -func (s *logsReceiver) Shutdown(ctx context.Context) error { +func (s *logsReceiver) Shutdown(_ context.Context) error { close(s.stopperChan) s.wg.Wait() return s.client.Shutdown() diff --git a/receiver/mongodbreceiver/client.go b/receiver/mongodbreceiver/client.go index 517d7eef9e341..9b5b3dd2de9dd 100644 --- a/receiver/mongodbreceiver/client.go +++ b/receiver/mongodbreceiver/client.go @@ -83,7 +83,7 @@ func (c *mongodbClient) TopStats(ctx context.Context) (bson.M, error) { // more information can be found here: https://pkg.go.dev/go.mongodb.org/mongo-driver@v1.9.0/mongo#Database.ListCollectionNames func (c *mongodbClient) ListCollectionNames(ctx context.Context, database string) ([]string, error) { lcOpts := options.ListCollections().SetAuthorizedCollections(true) - return c.Database(database).ListCollectionNames(context.Background(), bson.D{}, lcOpts) + return c.Database(database).ListCollectionNames(ctx, bson.D{}, lcOpts) } // IndexStats returns the index stats per collection for a given database diff --git a/receiver/mysqlreceiver/scraper.go b/receiver/mysqlreceiver/scraper.go index 63cea2a1748c1..0dadd833d47f7 100644 --- a/receiver/mysqlreceiver/scraper.go +++ b/receiver/mysqlreceiver/scraper.go @@ -47,7 +47,7 @@ func newMySQLScraper( } // start starts the scraper by initializing the db client connection. -func (m *mySQLScraper) start(_ context.Context, host component.Host) error { +func (m *mySQLScraper) start(_ context.Context, _ component.Host) error { sqlclient := newMySQLClient(m.config) err := sqlclient.Connect() diff --git a/receiver/nsxtreceiver/factory.go b/receiver/nsxtreceiver/factory.go index d034dbac2d267..480bb7eeb2a60 100644 --- a/receiver/nsxtreceiver/factory.go +++ b/receiver/nsxtreceiver/factory.go @@ -33,7 +33,7 @@ func createDefaultConfig() component.Config { } } -func createMetricsReceiver(ctx context.Context, params receiver.CreateSettings, rConf component.Config, consumer consumer.Metrics) (receiver.Metrics, error) { +func createMetricsReceiver(_ context.Context, params receiver.CreateSettings, rConf component.Config, consumer consumer.Metrics) (receiver.Metrics, error) { cfg, ok := rConf.(*Config) if !ok { return nil, errConfigNotNSX diff --git a/receiver/nsxtreceiver/scraper.go b/receiver/nsxtreceiver/scraper.go index cd13710ea32c6..2c2a2b9d2f34f 100644 --- a/receiver/nsxtreceiver/scraper.go +++ b/receiver/nsxtreceiver/scraper.go @@ -36,7 +36,7 @@ func newScraper(cfg *Config, settings receiver.CreateSettings) *scraper { } } -func (s *scraper) start(ctx context.Context, host component.Host) error { +func (s *scraper) start(_ context.Context, host component.Host) error { s.host = host client, err := newClient(s.config, s.settings, s.host, s.settings.Logger) if err != nil {