bulk-cdk-toolkit-load-gcs/io.airbyte.cdk.load.file.gcs/GcsNativeClient

GcsNativeClient

class GcsNativeClient(storage: Storage, config: GcsClientConfiguration) : GcsClient

THis client should be used when we finally decide to support native GCP auth. We can then swap over to this client instead of the GcsS3Client which will require us to use HMAC auth.

Constructors

GcsNativeClient

constructor(storage: Storage, config: GcsClientConfiguration)

Functions

delete

open suspend override fun delete(remoteObject: GcsBlob)

open suspend override fun delete(key: String)

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

get

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

getMetadata

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

list

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

move

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

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

put

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

startStreamingUpload

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