Skip to content

Commit af44238

Browse files
committed
replace deprecated method
1 parent 65ace62 commit af44238

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

plugins/destination/s3/client/client.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,7 @@ func New(ctx context.Context, logger zerolog.Logger, spec []byte, opts plugin.Ne
6161
}
6262

6363
cfg.Region = c.spec.Region
64-
cfg.EndpointResolverWithOptions = c
64+
cfg.WithEndpointResolverV2 = c
6565

6666
c.s3Client = s3.NewFromConfig(cfg)
6767
c.uploader = manager.NewUploader(c.s3Client)
@@ -95,7 +95,7 @@ func (c *Client) Close(ctx context.Context) error {
9595
return c.writer.Close(ctx)
9696
}
9797

98-
func (c *Client) ResolveEndpoint(service, region string, options ...any) (aws.Endpoint, error) {
98+
func (c *Client) WithEndpointResolverV2(service, region string, options ...any) (aws.Endpoint, error) {
9999
if c.spec.Endpoint == "" || service != s3.ServiceID {
100100
return aws.Endpoint{}, &aws.EndpointNotFoundError{}
101101
}

0 commit comments

Comments
 (0)