[processor/resourcedetection] update to aws-sdk-go-v2 (open-telemetry#39368)

<!--Ex. Fixing a bug - Describe the bug and how this fixes the issue.
Ex. Adding a feature - Explain what this achieves.-->
#### Description
aws-sdk-go is being [deprecated on July 31,
2025](https://aws.amazon.com/blogs/developer/announcing-end-of-support-for-aws-sdk-for-go-v1-on-july-31-2025/).
This PR updates `processor/resourcedetection` to aws-sdk-go-v2.

<!-- Issue number (e.g. open-telemetry#1234) or full URL to issue, if applicable. -->
#### Link to tracking issue
Fixes open-telemetry#37730  

<!--Describe what testing was performed and which tests were added.-->
#### Testing
I converted the existing unit tests to aws-sdk-go-v2 as well, keeping
the original intent of the tests.

Signed-off-by: Michael Shen <[email protected]>

Author: mjlshen

processor/resourcedetectionprocessor/go.mod

@@ -5,7 +5,6 @@ go 1.23.0
 require (
 	cloud.google.com/go/compute/metadata v0.6.0
 	github.com/GoogleCloudPlatform/opentelemetry-operations-go/detectors/gcp v1.27.0
-	github.com/aws/aws-sdk-go v1.55.6
 	github.com/aws/aws-sdk-go-v2 v1.36.3
 	github.com/aws/aws-sdk-go-v2/config v1.29.13
 	github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.16.30
@@ -93,7 +92,6 @@ require (
 	github.com/hashicorp/go-version v1.7.0 // indirect
 	github.com/hashicorp/golang-lru v1.0.2 // indirect
 	github.com/hashicorp/serf v0.10.1 // indirect
-	github.com/jmespath/go-jmespath v0.4.0 // indirect
 	github.com/josharian/intern v1.0.0 // indirect
 	github.com/json-iterator/go v1.1.12 // indirect
 	github.com/klauspost/compress v1.18.0 // indirect

processor/resourcedetectionprocessor/go.sum

@@ -10,10 +10,10 @@ import (
 	"os"
 	"strings"
 
-	"github.com/aws/aws-sdk-go/aws"
-	"github.com/aws/aws-sdk-go/aws/ec2metadata"
-	"github.com/aws/aws-sdk-go/aws/session"
-	"github.com/aws/aws-sdk-go/service/ec2"
+	"github.com/aws/aws-sdk-go-v2/config"
+	"github.com/aws/aws-sdk-go-v2/feature/ec2/imds"
+	"github.com/aws/aws-sdk-go-v2/service/ec2"
+	"github.com/aws/aws-sdk-go-v2/service/ec2/types"
 	"go.opentelemetry.io/collector/pdata/pcommon"
 	"go.opentelemetry.io/collector/processor"
 	conventions "go.opentelemetry.io/collector/semconv/v1.6.1"
@@ -43,7 +43,7 @@ const (
 type detectorUtils interface {
 	getConfigMap(ctx context.Context, namespace string, name string) (map[string]string, error)
 	getClusterName(ctx context.Context, logger *zap.Logger) string
-	getClusterNameTagFromReservations([]*ec2.Reservation) string
+	getClusterNameTagFromReservations([]types.Reservation) string
 	getCloudAccountID(ctx context.Context, logger *zap.Logger) string
 }
 
@@ -142,29 +142,31 @@ func (e eksDetectorUtils) getConfigMap(ctx context.Context, namespace string, na
 
 func (e eksDetectorUtils) getClusterName(ctx context.Context, logger *zap.Logger) string {
 	defaultErrorMessage := "Unable to get EKS cluster name"
-	sess, err := session.NewSession()
+	cfg, err := config.LoadDefaultConfig(ctx)
 	if err != nil {
 		logger.Warn(defaultErrorMessage, zap.Error(err))
 		return ""
 	}
 
-	ec2Svc := ec2metadata.New(sess)
-	region, err := ec2Svc.Region()
+	imdsClient := imds.NewFromConfig(cfg)
+	resp, err := imdsClient.GetRegion(ctx, &imds.GetRegionInput{})
 	if err != nil {
 		logger.Warn(defaultErrorMessage, zap.Error(err))
 		return ""
 	}
 
-	svc := ec2.New(sess, aws.NewConfig().WithRegion(region))
-	instanceIdentityDocument, err := ec2Svc.GetInstanceIdentityDocumentWithContext(ctx)
+	cfg.Region = resp.Region
+	ec2Client := ec2.NewFromConfig(cfg)
+
+	instanceIdentityDocument, err := imdsClient.GetInstanceIdentityDocument(ctx, &imds.GetInstanceIdentityDocumentInput{})
 	if err != nil {
 		logger.Warn(defaultErrorMessage, zap.Error(err))
 		return ""
 	}
 
-	instances, err := svc.DescribeInstances(&ec2.DescribeInstancesInput{
-		InstanceIds: []*string{
-			aws.String(instanceIdentityDocument.InstanceID),
+	instances, err := ec2Client.DescribeInstances(ctx, &ec2.DescribeInstancesInput{
+		InstanceIds: []string{
+			instanceIdentityDocument.InstanceID,
 		},
 	})
 	if err != nil {
@@ -181,7 +183,7 @@ func (e eksDetectorUtils) getClusterName(ctx context.Context, logger *zap.Logger
 	return clusterName
 }
 
-func (e eksDetectorUtils) getClusterNameTagFromReservations(reservations []*ec2.Reservation) string {
+func (e eksDetectorUtils) getClusterNameTagFromReservations(reservations []types.Reservation) string {
 	for _, reservation := range reservations {
 		for _, instance := range reservation.Instances {
 			for _, tag := range instance.Tags {
@@ -203,14 +205,14 @@ func (e eksDetectorUtils) getClusterNameTagFromReservations(reservations []*ec2.
 
 func (e eksDetectorUtils) getCloudAccountID(ctx context.Context, logger *zap.Logger) string {
 	defaultErrorMessage := "Unable to get EKS cluster account ID"
-	sess, err := session.NewSession()
+	cfg, err := config.LoadDefaultConfig(ctx)
 	if err != nil {
 		logger.Warn(defaultErrorMessage, zap.Error(err))
 		return ""
 	}
 
-	ec2Svc := ec2metadata.New(sess)
-	instanceIdentityDocument, err := ec2Svc.GetInstanceIdentityDocumentWithContext(ctx)
+	imdsClient := imds.NewFromConfig(cfg)
+	instanceIdentityDocument, err := imdsClient.GetInstanceIdentityDocument(ctx, &imds.GetInstanceIdentityDocumentInput{})
 	if err != nil {
 		logger.Warn(defaultErrorMessage, zap.Error(err))
 		return ""

processor/resourcedetectionprocessor/internal/aws/eks/detector.go

@@ -7,7 +7,7 @@ import (
 	"context"
 	"testing"
 
-	"github.com/aws/aws-sdk-go/service/ec2"
+	"github.com/aws/aws-sdk-go-v2/service/ec2/types"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/mock"
 	"github.com/stretchr/testify/require"
@@ -33,11 +33,11 @@ func (detectorUtils *MockDetectorUtils) getConfigMap(_ context.Context, namespac
 }
 
 func (detectorUtils *MockDetectorUtils) getClusterName(_ context.Context, _ *zap.Logger) string {
-	var reservations []*ec2.Reservation
+	var reservations []types.Reservation
 	return detectorUtils.getClusterNameTagFromReservations(reservations)
 }
 
-func (detectorUtils *MockDetectorUtils) getClusterNameTagFromReservations(_ []*ec2.Reservation) string {
+func (detectorUtils *MockDetectorUtils) getClusterNameTagFromReservations(_ []types.Reservation) string {
 	return clusterName
 }