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

AirbyteConnectorRunnable

class AirbyteConnectorRunnable : Runnable

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

Constructors

Link copied to clipboard
constructor()

Properties

Link copied to clipboard
@Value(value = "${airbyte.connector.metadata.docker-repository}")
lateinit value var connectorName: String
Link copied to clipboard
@Inject
lateinit var exceptionHandler: ExceptionHandler
Link copied to clipboard
@Value(value = "${airbyte.connector.operation}")
lateinit value var operationName: String
Link copied to clipboard
@Inject
lateinit var operationProvider: Provider<Operation>
Link copied to clipboard
@Inject
lateinit var outputConsumer: OutputConsumer

Functions

Link copied to clipboard
open override fun run()