Package-level declarations
Functions
Link copied to clipboard
fun <Error class: unknown class>.download( builder: <Error class: unknown class>.() -> Unit): Flow<Pair<<Error class: unknown class>, Flow<ByteArray>>>
fun <Error class: unknown class>.download(bucket: String, key: String): Flow<Pair<<Error class: unknown class>, Flow<ByteArray>>>
Creates a flow that downloads a file from an Amazon S3 bucket.
Link copied to clipboard
fun <Error class: unknown class>.mergeContents( files: List<Pair<String, String>>, concurrency: Int = 1, destination: <Error class: unknown class>.() -> Unit): Flow<S3Response<*>>
This function performs a merge by using multipart upload copy operations using the S3Client. It copies multiple source files into a single destination object in an S3 bucket.
Link copied to clipboard
fun <Error class: unknown class>.selectObjectContent(request: <Error class: unknown class>.() -> Unit): Flow<<Error class: unknown class>>
A function that performs a select object content operation on a file from an Amazon S3 bucket, which allows retrieving a subset of data from an object by using simple SQL expressions.
Link copied to clipboard
fun <Error class: unknown class>.upload( upstream: Flow<ByteArray>, concurrency: Int = 1, initialRequest: <Error class: unknown class>.() -> Unit): Flow<S3Response.MultipartResponse<*>>
fun <Error class: unknown class>.upload( bucket: String, key: String, upstream: Flow<ByteArray>, concurrency: Int = 1): Flow<S3Response.MultipartResponse<*>>
Creates a flow that uploads byte arrays to an Amazon S3 bucket.
Link copied to clipboard
fun <Error class: unknown class>.uploadBytes( upstream: Flow<Byte>, concurrency: Int = 1, initialRequest: <Error class: unknown class>.() -> Unit): Flow<S3Response.MultipartResponse<*>>
fun <Error class: unknown class>.uploadBytes( bucket: String, key: String, upstream: Flow<Byte>, concurrency: Int = 1): Flow<S3Response.MultipartResponse<*>>
Creates a flow that uploads bytes to an Amazon S3 bucket.
Link copied to clipboard
fun <Error class: unknown class>.uploadSplit( bucket: String, upstream: Flow<Byte>, splitStrategy: GroupStrategy = GroupStrategy.Count(ONE_MB), concurrency: Int = 1, key: (Int) -> String): Flow<S3Response<*>>
This function uploads a file in chunks to an Amazon S3 bucket using the S3Client.
Link copied to clipboard
fun <T> <Error class: unknown class>.uploadSplitItems( bucket: String, upstream: Flow<T>, splitStrategy: GroupStrategy = GroupStrategy.Count(1000), concurrency: Int = 1, key: (Int) -> String, f: suspend (T) -> ByteArray): Flow<S3Response<*>>
This function uploads a file in chunks to an Amazon S3 bucket using the S3Client.