Skip to content
This repository was archived by the owner on Mar 18, 2026. It is now read-only.

Update examples to use EndpointResolverV2 #10

Open
packrat386 wants to merge 1 commit into
base: main
Choose a base branch
from
Open

Update examples to use EndpointResolverV2 #10

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
33 changes: 19 additions & 14 deletions go/s3/s3-crud-sdk-v2/main.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -11,6 +11,7 @@ import (
"github.com/aws/aws-sdk-go-v2/config"
"github.com/aws/aws-sdk-go-v2/service/s3"
"github.com/aws/aws-sdk-go-v2/service/s3/types"
smithyendpoints "github.com/aws/smithy-go/endpoints"
)

var (
Expand All @@ -30,29 +31,16 @@ func init() {
awsEndpoint = "http://localhost:4566"
bucketName = "test"

customResolver := aws.EndpointResolverWithOptionsFunc(func(service, region string, options ...interface{}) (aws.Endpoint, error) {
if awsEndpoint != "" {
return aws.Endpoint{
PartitionID: "aws",
URL: awsEndpoint,
SigningRegion: awsRegion,
}, nil
}

// returning EndpointNotFoundError will allow the service to fallback to it's default resolution
return aws.Endpoint{}, &aws.EndpointNotFoundError{}
})

awsCfg, err := config.LoadDefaultConfig(context.TODO(),
config.WithRegion(awsRegion),
config.WithEndpointResolverWithOptions(customResolver),
)
if err != nil {
log.Fatalf("Cannot load the AWS configs: %s", err)
}

s3svc = s3.NewFromConfig(awsCfg, func(o *s3.Options) {
o.UsePathStyle = true
o.EndpointResolverV2 = newLocalstackEndpointResolver(awsEndpoint)
})
}

Expand Down Expand Up @@ -115,3 +103,20 @@ func main() {
}
s3svc.DeleteObjects(context.TODO(), &input)
}

type localstackEndpointResolver struct {
inner s3.EndpointResolverV2
endpoint *string
}

func newLocalstackEndpointResolver(endpoint string) *localstackEndpointResolver {
return &localstackEndpointResolver{
inner: s3.NewDefaultEndpointResolverV2(),
endpoint: &endpoint,
}
}

func (l *localstackEndpointResolver) ResolveEndpoint(ctx context.Context, params s3.EndpointParameters) (smithyendpoints.Endpoint, error) {
params.Endpoint = l.endpoint
return l.inner.ResolveEndpoint(ctx, params)
}