bulk-cdk-core-base/io.airbyte.cdk

Package-level declarations

Types

class AirbyteConnectorRunnable : Runnable

AirbyteConnectorRunner tells Micronaut to use this Runnable as the entry point.

Replacement for the Micronaut CLI application runner that configures the CLI components and adds the custom property source used to turn the arguments into configuration properties.

AirbyteDestinationRunner

class AirbyteDestinationRunner(val args: Array<out String>, additionalMicronautEnvs: List<String> = emptyList(), systemEnv: Map<String, String> = System.getenv(), val micronautProperties: Map<String, String> = emptyMap(), val testBeanDefinitions: RuntimeBeanDefinition<*>) : AirbyteConnectorRunner

Destination connector entry point.

AirbyteSourceRunner

class AirbyteSourceRunner(val args: Array<out String>, additionalMicronautEnvs: List<String> = emptyList(), systemEnv: Map<String, String> = System.getenv(), val testBeanDefinitions: RuntimeBeanDefinition<*>) : AirbyteConnectorRunner

Source connector entry point.

ClockFactory

@Factory

class ClockFactory

Injects the system clock in production and a fake clock in tests.

ConfigErrorException