s3: Do not use deprecated EndpointResolver
#193
1 changed files with 1 additions and 10 deletions
|
@ -53,17 +53,8 @@ func (s *S3) Exports() modules.Exports {
|
||||||
}
|
}
|
||||||
|
|
||||||
func (s *S3) Connect(endpoint string, params map[string]string) (*Client, error) {
|
func (s *S3) Connect(endpoint string, params map[string]string) (*Client, error) {
|
||||||
// TODO: #192 Do not use deprecated `aws.EndpointResolver`
|
|
||||||
// nolint:staticcheck
|
|
||||||
resolver := aws.EndpointResolverWithOptionsFunc(func(_, _ string, _ ...interface{}) (aws.Endpoint, error) {
|
|
||||||
return aws.Endpoint{
|
|
||||||
URL: endpoint,
|
|
||||||
}, nil
|
|
||||||
})
|
|
||||||
|
|
||||||
// nolint:staticcheck
|
|
||||||
cfg, err := config.LoadDefaultConfig(s.vu.Context(),
|
cfg, err := config.LoadDefaultConfig(s.vu.Context(),
|
||||||
config.WithEndpointResolverWithOptions(resolver),
|
config.WithBaseEndpoint(endpoint),
|
||||||
config.WithSharedConfigProfile(params["aws_profile"]))
|
config.WithSharedConfigProfile(params["aws_profile"]))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, fmt.Errorf("configuration error: %w", err)
|
return nil, fmt.Errorf("configuration error: %w", err)
|
||||||
|
|
Loading…
Add table
Reference in a new issue