feat: s3 transfer manager client

Author: 0marperez

aws-runtime/aws-http/api/aws-http.api

@@ -171,6 +171,7 @@ public final class aws/sdk/kotlin/runtime/http/interceptors/IgnoreCompositeFlexi
 public final class aws/sdk/kotlin/runtime/http/interceptors/businessmetrics/AwsBusinessMetric : java/lang/Enum, aws/smithy/kotlin/runtime/businessmetrics/BusinessMetric {
 	public static final field DDB_MAPPER Laws/sdk/kotlin/runtime/http/interceptors/businessmetrics/AwsBusinessMetric;
 	public static final field S3_EXPRESS_BUCKET Laws/sdk/kotlin/runtime/http/interceptors/businessmetrics/AwsBusinessMetric;
+	public static final field S3_TRANSFER Laws/sdk/kotlin/runtime/http/interceptors/businessmetrics/AwsBusinessMetric;
 	public static fun getEntries ()Lkotlin/enums/EnumEntries;
 	public fun getIdentifier ()Ljava/lang/String;
 	public fun toString ()Ljava/lang/String;

aws-runtime/aws-http/common/src/aws/sdk/kotlin/runtime/http/interceptors/businessmetrics/AwsBusinessMetricsUtils.kt

@@ -62,6 +62,7 @@ internal fun formatMetrics(metrics: MutableSet<BusinessMetric>, logger: Logger):
 public enum class AwsBusinessMetric(public override val identifier: String) : BusinessMetric {
     S3_EXPRESS_BUCKET("J"),
     DDB_MAPPER("d"),
+    S3_TRANSFER("G"),
     ;
 
     @InternalApi

hll/build.gradle.kts

@@ -45,7 +45,7 @@ val hllPreviewVersion = if (sdkVersion.contains("-SNAPSHOT")) { // e.g. 1.3.29-b
 
 subprojects {
     group = "aws.sdk.kotlin"
-    version = hllPreviewVersion
+    version = if (name == "s3-transfer-manager") sdkVersion else hllPreviewVersion
     // TODO Use configurePublishing when migrating to Sonatype Publisher API / JReleaser
     configurePublishing("aws-sdk-kotlin")
 }

hll/s3-transfer-manager/api/s3-transfer-manager.api

@@ -0,0 +1,4 @@
+public final class aws/sdk/kotlin/hll/s3transfermanager/S3TransferManager {
+	public fun <init> ()V
+}
+

hll/s3-transfer-manager/build.gradle.kts

@@ -0,0 +1,19 @@
+/*
+ * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+description = "S3 Transfer Manager for the AWS SDK for Kotlin"
+extra["displayName"] = "AWS :: SDK :: Kotlin :: HLL :: S3TransferManager"
+extra["moduleName"] = "aws.sdk.kotlin.hll.s3transfermanager"
+
+kotlin {
+    sourceSets {
+        commonMain {
+            dependencies {
+                implementation(project(":aws-runtime:aws-http"))
+                implementation(project(":services:s3"))
+            }
+        }
+    }
+}

hll/s3-transfer-manager/common/src/aws/sdk/kotlin/hll/s3transfermanager/BusinessMetricInterceptor.kt

@@ -0,0 +1,16 @@
+package aws.sdk.kotlin.hll.s3transfermanager
+
+import aws.sdk.kotlin.runtime.http.interceptors.businessmetrics.AwsBusinessMetric
+import aws.smithy.kotlin.runtime.businessmetrics.emitBusinessMetric
+import aws.smithy.kotlin.runtime.client.RequestInterceptorContext
+import aws.smithy.kotlin.runtime.http.interceptors.HttpInterceptor
+
+/**
+ * An interceptor that emits the S3 Transfer Manager business metric
+ */
+internal object BusinessMetricInterceptor : HttpInterceptor {
+    override suspend fun modifyBeforeSerialization(context: RequestInterceptorContext<Any>): Any {
+        context.executionContext.emitBusinessMetric(AwsBusinessMetric.S3_TRANSFER)
+        return context.request
+    }
+}

hll/s3-transfer-manager/common/src/aws/sdk/kotlin/hll/s3transfermanager/MultiPartDownloadType.kt

@@ -0,0 +1,16 @@
+package aws.sdk.kotlin.hll.s3transfermanager
+
+/**
+ * TODO
+ */
+public sealed interface MultiPartDownloadType
+
+/**
+ * TODO
+ */
+public object Range : MultiPartDownloadType
+
+/**
+ * TODO
+ */
+public object Part : MultiPartDownloadType

hll/s3-transfer-manager/common/src/aws/sdk/kotlin/hll/s3transfermanager/S3TransferManager.kt

@@ -0,0 +1,44 @@
+/*
+ * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package aws.sdk.kotlin.hll.s3transfermanager
+
+import aws.sdk.kotlin.services.s3.S3Client
+import aws.sdk.kotlin.services.s3.withConfig
+
+/**
+ * High level utility for managing transfers to Amazon S3.
+ */
+public class S3TransferManager private constructor(
+    public val client: S3Client,
+    public val partSize: Long?,
+    public val multipartUploadThreshold: Long?,
+    public val multipartDownloadType: MultiPartDownloadType?,
+    public val interceptors: MutableList<TransferInterceptor>?,
+) {
+    public companion object {
+        public operator fun invoke(block: Builder.() -> Unit): S3TransferManager =
+            Builder().apply(block).build()
+    }
+
+    public class Builder {
+        public var client: S3Client? = null
+        public var partSize: Long? = 8_000_000L
+        public var multipartUploadThreshold: Long? = 16_000_000L
+        public var multipartDownloadType: MultiPartDownloadType? = Part
+        public var interceptors: MutableList<TransferInterceptor>? = mutableListOf()
+
+        internal fun build(): S3TransferManager =
+            S3TransferManager(
+                client = client?.withConfig { interceptors += BusinessMetricInterceptor } ?: error("client must be set"),
+                partSize = partSize,
+                multipartUploadThreshold = multipartUploadThreshold,
+                multipartDownloadType = multipartDownloadType,
+                interceptors = interceptors
+            )
+    }
+
+    public fun x(): String = "" // TODO
+}

hll/s3-transfer-manager/common/src/aws/sdk/kotlin/hll/s3transfermanager/TransferInterceptor.kt

@@ -0,0 +1,5 @@
+package aws.sdk.kotlin.hll.s3transfermanager
+
+public class TransferInterceptor {
+    // TODO
+}

settings.gradle.kts

@@ -57,6 +57,7 @@ include(":aws-runtime:aws-http")
 include(":hll")
 include(":hll:hll-codegen")
 include(":hll:hll-mapping-core")
+include(":hll:s3-transfer-manager")
 include(":services")
 include(":tests")
 include(":tests:codegen")