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

AirbyteSourceRunner

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

Source connector entry point.

Constructors

AirbyteSourceRunner

constructor(args: Array<out String>, additionalMicronautEnvs: List<String> = emptyList(), systemEnv: Map<String, String> = System.getenv(), vararg testBeanDefinitions: RuntimeBeanDefinition<*>)

Types

Companion

object Companion

Properties

args

val args: Array<out String>

connectorType

val connectorType: String

envs

val envs: Array<String>

micronautProperties

val micronautProperties: Map<String, String>

testBeanDefinitions

val testBeanDefinitions: Array<out RuntimeBeanDefinition<*>>

Functions

run

inline fun <R : Runnable> run()