Airbyte Kotlin Bulk CDK

0.1.92

bulk-cdk-toolkit-load-s3/io.airbyte.cdk.load.file.s3/S3KotlinClient

S3KotlinClient

class S3KotlinClient(client: S3Client, val bucketConfig: S3BucketConfiguration) : S3Client

The primary and recommended S3 client implementation -- kotlin-friendly with suspend functions. However, there's a bug that can cause hard failures under high-concurrency. (Partial workaround in place https://github.com/awslabs/aws-sdk-kotlin/issues/1214#issuecomment-2464831817).

Constructors

constructor(client: S3Client, bucketConfig: S3BucketConfiguration)

Properties

val bucketConfig: S3BucketConfiguration

Functions

open suspend override fun delete(remoteObject: S3Object)

open suspend override fun delete(key: String)

open suspend override fun delete(keys: Set<String>)

open suspend override fun <R> get(key: String, block: (InputStream) -> R): R

open suspend override fun getMetadata(key: String): Map<String, String>

open suspend override fun list(prefix: String): Flow<S3Object>

open suspend override fun move(remoteObject: S3Object, toKey: String): S3Object

open suspend override fun move(key: String, toKey: String): S3Object

open suspend override fun put(key: String, bytes: ByteArray): S3Object

startStreamingUpload

open suspend override fun startStreamingUpload(key: String, metadata: Map<String, String>): StreamingUpload<S3Object>