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

GcsClient

interface GcsClient : ObjectStorageClient<GcsBlob>

Inheritors

Functions

Link copied to clipboard
abstract suspend fun delete(remoteObject: GcsBlob)
abstract suspend fun delete(key: String)
abstract suspend fun delete(keys: Set<String>)
Link copied to clipboard
abstract suspend fun <U> get(key: String, block: (InputStream) -> U): U
Link copied to clipboard
abstract suspend fun getMetadata(key: String): Map<String, String>
Link copied to clipboard
abstract suspend fun list(prefix: String): Flow<GcsBlob>
Link copied to clipboard
abstract suspend fun move(remoteObject: GcsBlob, toKey: String): GcsBlob
abstract suspend fun move(key: String, toKey: String): GcsBlob
Link copied to clipboard
abstract suspend fun put(key: String, bytes: ByteArray): GcsBlob
Link copied to clipboard
abstract suspend fun startStreamingUpload(key: String, metadata: Map<String, String>): StreamingUpload<GcsBlob>