xtdb-postgres-source/xtdb.postgres/PostgresSource/Factory

Factory

@Serializable

@SerialName(value = "!Postgres")

data class Factory(val remote: RemoteAlias, val slotName: String, val publicationName: String, val indexer: PgIndexer.Factory) : ExternalSource.Factory

Constructors

constructor(remote: RemoteAlias, slotName: String, publicationName: String, indexer: PgIndexer.Factory)

Types

class Registration : ExternalSource.Registration<PostgresSource.Factory>

Properties

val indexer: PgIndexer.Factory

publicationName

val publicationName: String

val remote: RemoteAlias

val slotName: String

Functions

open override fun open(dbName: String, remotes: Map<RemoteAlias, Remote>, meterRegistry: MeterRegistry?): ExternalSource