Airbyte Kotlin Bulk CDK

0.1.92

bulk-cdk-toolkit-load-dlq/io.airbyte.cdk.load.command.dlq

Package-level declarations

Types

ConfigurationSpecificationWithDlq

abstract class ConfigurationSpecificationWithDlq(val objectStorageConfig: ObjectStorageSpec? = DisabledObjectStorageSpec()) : ConfigurationSpecification

DisabledObjectStorageConfig

class DisabledObjectStorageConfig : ObjectStorageConfig

DisabledObjectStorageSpec

class DisabledObjectStorageSpec : ObjectStorageSpec

ObjectStorageConfig

sealed interface ObjectStorageConfig

ObjectStorageConfigProvider

interface ObjectStorageConfigProvider

ObjectStorageSpec

sealed interface ObjectStorageSpec

ObjectStorageType

enum ObjectStorageType : Enum<ObjectStorageType>

S3ObjectStorageConfig

class S3ObjectStorageConfig<T : OutputStream>(val awsAccessKeyConfiguration: AWSAccessKeyConfiguration, val awsArnRoleConfiguration: AWSArnRoleConfiguration, val s3BucketConfiguration: S3BucketConfiguration, val objectStorageCompressionConfiguration: ObjectStorageCompressionConfiguration<T>, val objectStorageFormatConfiguration: ObjectStorageFormatConfiguration, val objectStoragePathConfiguration: ObjectStoragePathConfiguration) : ObjectStorageConfig, AWSAccessKeyConfigurationProvider, AWSArnRoleConfigurationProvider, S3BucketConfigurationProvider, ObjectStorageCompressionConfigurationProvider<T> , ObjectStorageFormatConfigurationProvider, ObjectStoragePathConfigurationProvider

S3ObjectStorageSpec

class S3ObjectStorageSpec : ObjectStorageSpec, ObjectStorageCompressionSpecificationProvider, ObjectStorageFormatSpecificationProvider, AWSAccessKeySpecification, AWSArnRoleSpecification, S3BucketSpecification

Properties

const val ALWAYS_SHOW: String

const val HIDDEN: String

const val SECRET: String

Functions

toObjectStorageConfig

fun ObjectStorageSpec?.toObjectStorageConfig(): ObjectStorageConfig