StateManagerFactory

@Singleton

class StateManagerFactory(val metadataQuerierFactory: MetadataQuerier.Factory<SourceConfiguration>, val metaFieldDecorator: MetaFieldDecorator, val outputConsumer: OutputConsumer, val handler: CatalogValidationFailureHandler, @Value(value = "${airbyte.connector.data-channel.medium}") val dataChannelMedium: String, @Value(value = "${airbyte.connector.data-channel.format}") val dataChannelFormat: String)

A factory for instantiating StateManager based on the inputs of a READ. These inputs are deliberately not injected here to make testing easier.

Constructors

constructor(metadataQuerierFactory: MetadataQuerier.Factory<SourceConfiguration>, metaFieldDecorator: MetaFieldDecorator, outputConsumer: OutputConsumer, handler: CatalogValidationFailureHandler, @Value(value = "${airbyte.connector.data-channel.medium}") dataChannelMedium: String, @Value(value = "${airbyte.connector.data-channel.format}") dataChannelFormat: String)

fun create(config: SourceConfiguration, configuredCatalog: ConfiguredAirbyteCatalog, inputState: InputState): StateManager

Generates a StateManager instance based on the provided inputs.