From b4aaf420bceaee1f16c4b39cb293867e27ba76a7 Mon Sep 17 00:00:00 2001 From: DarthSim Date: Sun, 23 Mar 2025 18:50:40 +0300 Subject: [PATCH] Cleanup S3 transport --- transport/s3/s3.go | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/transport/s3/s3.go b/transport/s3/s3.go index 0816e8fa..f64db5e9 100644 --- a/transport/s3/s3.go +++ b/transport/s3/s3.go @@ -28,7 +28,6 @@ import ( type s3Client interface { GetObject(ctx context.Context, input *s3.GetObjectInput, opts ...func(*s3.Options)) (*s3.GetObjectOutput, error) - HeadBucket(ctx context.Context, input *s3.HeadBucketInput, optFns ...func(*s3.Options)) (*s3.HeadBucketOutput, error) } // transport implements RoundTripper for the 's3' protocol. @@ -162,7 +161,7 @@ func (t *transport) RoundTrip(req *http.Request) (*http.Response, error) { // Check if the error is the region mismatch error. // If so, create a new client with the correct region and retry the request. if region := regionFromError(err); len(region) != 0 { - client, err = t.createBucketClient(req.Context(), bucket, region) + client, err = t.createBucketClient(bucket, region) if err != nil { return handleError(req, err) } @@ -249,7 +248,7 @@ func (t *transport) getBucketClient(bucket string) s3Client { return t.defaultClient } -func (t *transport) createBucketClient(ctx context.Context, bucket, region string) (s3Client, error) { +func (t *transport) createBucketClient(bucket, region string) (s3Client, error) { t.mu.Lock() defer t.mu.Unlock()