Migrate Go v2 S3 examples from deprecated feature/s3/manager to feature/s3/transfermanager

The feature/s3/manager package was deprecated in February 2026 and replaced
by feature/s3/transfermanager. This commit migrates all Go SDK v2 examples
to use the new package.

Key changes:
- Replace manager.NewUploader/NewDownloader with transfermanager.New (unified client)
- Replace uploader.Upload with tmClient.UploadObject (new UploadObjectInput type)
- Replace downloader.Download with tmClient.DownloadObject (new DownloadObjectInput type)
- Replace manager.NewWriteAtBuffer with tmtypes.NewWriteAtBuffer
- Configure PartSize via Options.PartSizeBytes on the client
- Use transfermanager/types.ChecksumAlgorithmSha256 for checksum config
- Update go.mod dependencies from feature/s3/manager to feature/s3/transfermanager

Files modified:
- gov2/s3/actions/bucket_basics.go (UploadLargeObject, DownloadLargeObject)
- gov2/s3/go.mod
- gov2/workflows/s3_object_lock/actions/s3_actions.go (S3Actions struct, UploadObject)
- gov2/workflows/s3_object_lock/actions/s3_actions_test.go
- gov2/workflows/s3_object_lock/workflows/s3_object_lock.go
- gov2/workflows/s3_object_lock/go.mod

Author: brmur

gov2/s3/actions/bucket_basics.go

@@ -17,7 +17,8 @@ import (
 	"time"
 
 	"github.com/aws/aws-sdk-go-v2/aws"
-	"github.com/aws/aws-sdk-go-v2/feature/s3/manager"
+	"github.com/aws/aws-sdk-go-v2/feature/s3/transfermanager"
+	tmtypes "github.com/aws/aws-sdk-go-v2/feature/s3/transfermanager/types"
 	"github.com/aws/aws-sdk-go-v2/service/s3"
 	"github.com/aws/aws-sdk-go-v2/service/s3/types"
 	"github.com/aws/smithy-go"
@@ -162,15 +163,15 @@ func (basics BucketBasics) UploadFile(ctx context.Context, bucketName string, ob
 
 // snippet-start:[gov2.s3.Upload]
 
-// UploadLargeObject uses an upload manager to upload data to an object in a bucket.
-// The upload manager breaks large data into parts and uploads the parts concurrently.
+// UploadLargeObject uses the S3 transfer manager to upload data to an object in a bucket.
+// The transfer manager breaks large data into parts and uploads the parts concurrently.
 func (basics BucketBasics) UploadLargeObject(ctx context.Context, bucketName string, objectKey string, largeObject []byte) error {
 	largeBuffer := bytes.NewReader(largeObject)
 	var partMiBs int64 = 10
-	uploader := manager.NewUploader(basics.S3Client, func(u *manager.Uploader) {
-		u.PartSize = partMiBs * 1024 * 1024
+	tmClient := transfermanager.New(basics.S3Client, func(o *transfermanager.Options) {
+		o.PartSizeBytes = partMiBs * 1024 * 1024
 	})
-	_, err := uploader.Upload(ctx, &s3.PutObjectInput{
+	_, err := tmClient.UploadObject(ctx, &transfermanager.UploadObjectInput{
 		Bucket: aws.String(bucketName),
 		Key:    aws.String(objectKey),
 		Body:   largeBuffer,
@@ -234,18 +235,19 @@ func (basics BucketBasics) DownloadFile(ctx context.Context, bucketName string,
 
 // snippet-start:[gov2.s3.Download]
 
-// DownloadLargeObject uses a download manager to download an object from a bucket.
-// The download manager gets the data in parts and writes them to a buffer until all of
+// DownloadLargeObject uses the S3 transfer manager to download an object from a bucket.
+// The transfer manager gets the data in parts and writes them to a buffer until all of
 // the data has been downloaded.
 func (basics BucketBasics) DownloadLargeObject(ctx context.Context, bucketName string, objectKey string) ([]byte, error) {
 	var partMiBs int64 = 10
-	downloader := manager.NewDownloader(basics.S3Client, func(d *manager.Downloader) {
-		d.PartSize = partMiBs * 1024 * 1024
+	tmClient := transfermanager.New(basics.S3Client, func(o *transfermanager.Options) {
+		o.PartSizeBytes = partMiBs * 1024 * 1024
 	})
-	buffer := manager.NewWriteAtBuffer([]byte{})
-	_, err := downloader.Download(ctx, buffer, &s3.GetObjectInput{
-		Bucket: aws.String(bucketName),
-		Key:    aws.String(objectKey),
+	buffer := tmtypes.NewWriteAtBuffer([]byte{})
+	_, err := tmClient.DownloadObject(ctx, &transfermanager.DownloadObjectInput{
+		Bucket:   aws.String(bucketName),
+		Key:      aws.String(objectKey),
+		WriterAt: buffer,
 	})
 	if err != nil {
 		log.Printf("Couldn't download large object from %v:%v. Here's why: %v\n",

gov2/s3/go.mod

@@ -5,7 +5,7 @@ go 1.24
 require (
 	github.com/aws/aws-sdk-go-v2 v1.41.5
 	github.com/aws/aws-sdk-go-v2/config v1.27.33
-	github.com/aws/aws-sdk-go-v2/feature/s3/manager v1.17.18
+	github.com/aws/aws-sdk-go-v2/feature/s3/transfermanager v0.1.0
 	github.com/aws/aws-sdk-go-v2/service/s3 v1.97.3
 	github.com/aws/smithy-go v1.24.2
 	github.com/awsdocs/aws-doc-sdk-examples/gov2/demotools v0.0.0-20240907001412-a9375541143b

gov2/workflows/s3_object_lock/actions/s3_actions.go

@@ -15,7 +15,8 @@ import (
 	"time"
 
 	"github.com/aws/aws-sdk-go-v2/aws"
-	"github.com/aws/aws-sdk-go-v2/feature/s3/manager"
+	"github.com/aws/aws-sdk-go-v2/feature/s3/transfermanager"
+	tmtypes "github.com/aws/aws-sdk-go-v2/feature/s3/transfermanager/types"
 	"github.com/aws/aws-sdk-go-v2/service/s3"
 	"github.com/aws/aws-sdk-go-v2/service/s3/types"
 	"github.com/aws/smithy-go"
@@ -24,7 +25,7 @@ import (
 // S3Actions wraps S3 service actions.
 type S3Actions struct {
 	S3Client  *s3.Client
-	S3Manager *manager.Uploader
+	S3Manager *transfermanager.Client
 }
 
 // snippet-end:[gov2.workflows.s3.ObjectLock.S3Actions.struct]
@@ -303,16 +304,16 @@ func (actor S3Actions) PutObjectRetention(ctx context.Context, bucket string, ke
 
 // snippet-start:[gov2.workflows.s3.ObjectLock.UploadObject]
 
-// UploadObject uses the S3 upload manager to upload an object to a bucket.
+// UploadObject uses the S3 transfer manager to upload an object to a bucket.
 func (actor S3Actions) UploadObject(ctx context.Context, bucket string, key string, contents string) (string, error) {
 	var outKey string
-	input := &s3.PutObjectInput{
+	input := &transfermanager.UploadObjectInput{
 		Bucket:            aws.String(bucket),
 		Key:               aws.String(key),
 		Body:              bytes.NewReader([]byte(contents)),
-		ChecksumAlgorithm: types.ChecksumAlgorithmSha256,
+		ChecksumAlgorithm: tmtypes.ChecksumAlgorithmSha256,
 	}
-	output, err := actor.S3Manager.Upload(ctx, input)
+	output, err := actor.S3Manager.UploadObject(ctx, input)
 	if err != nil {
 		var noBucket *types.NoSuchBucket
 		if errors.As(err, &noBucket) {

gov2/workflows/s3_object_lock/actions/s3_actions_test.go

@@ -13,7 +13,7 @@ import (
 	"time"
 
 	"github.com/aws/aws-sdk-go-v2/aws"
-	"github.com/aws/aws-sdk-go-v2/feature/s3/manager"
+	"github.com/aws/aws-sdk-go-v2/feature/s3/transfermanager"
 	"github.com/aws/aws-sdk-go-v2/service/s3"
 	"github.com/aws/aws-sdk-go-v2/service/s3/types"
 	"github.com/aws/smithy-go"
@@ -142,7 +142,7 @@ func TestUploadObject(t *testing.T) {
 	ctx, stubber, actor := enterTest()
 	defer testtools.ExitTest(stubber, t)
 
-	actor.S3Manager = manager.NewUploader(actor.S3Client)
+	actor.S3Manager = transfermanager.New(actor.S3Client)
 	expectedErr, stubErr := wrapErr(&types.NoSuchBucket{})
 	checksum := types.ChecksumAlgorithmSha256
 	stubber.Add(stubs.StubPutObject("amzn-s3-demo-bucket", "test-key", &checksum, stubErr))

gov2/workflows/s3_object_lock/go.mod

@@ -5,7 +5,7 @@ go 1.24
 require (
 	github.com/aws/aws-sdk-go-v2 v1.41.5
 	github.com/aws/aws-sdk-go-v2/config v1.27.33
-	github.com/aws/aws-sdk-go-v2/feature/s3/manager v1.17.18
+	github.com/aws/aws-sdk-go-v2/feature/s3/transfermanager v0.1.0
 	github.com/aws/aws-sdk-go-v2/service/s3 v1.97.3
 	github.com/aws/smithy-go v1.24.2
 	github.com/awsdocs/aws-doc-sdk-examples/gov2/demotools v0.0.0-20240907001412-a9375541143b

gov2/workflows/s3_object_lock/workflows/s3_object_lock.go

@@ -14,7 +14,7 @@ import (
 	"s3_object_lock/actions"
 
 	"github.com/aws/aws-sdk-go-v2/aws"
-	"github.com/aws/aws-sdk-go-v2/feature/s3/manager"
+	"github.com/aws/aws-sdk-go-v2/feature/s3/transfermanager"
 	"github.com/aws/aws-sdk-go-v2/service/s3"
 	"github.com/aws/aws-sdk-go-v2/service/s3/types"
 	"github.com/awsdocs/aws-doc-sdk-examples/gov2/demotools"
@@ -36,7 +36,7 @@ func NewObjectLockScenario(sdkConfig aws.Config, questioner demotools.IQuestione
 		s3Actions:  &actions.S3Actions{S3Client: s3.NewFromConfig(sdkConfig)},
 		sdkConfig:  sdkConfig,
 	}
-	scenario.s3Actions.S3Manager = manager.NewUploader(scenario.s3Actions.S3Client)
+	scenario.s3Actions.S3Manager = transfermanager.New(scenario.s3Actions.S3Client)
 	scenario.resources.init(scenario.s3Actions, questioner)
 	return scenario
 }