xtdb-postgres-source/xtdb.postgres/PostgresSource

PostgresSource

class PostgresSource(dbName: String, driver: PostgresDriver, slotName: String, indexer: PgIndexer, meterRegistry: MeterRegistry? = null) : ExternalSource

Constructors

constructor(dbName: String, driver: PostgresDriver, slotName: String, indexer: PgIndexer, meterRegistry: MeterRegistry? = null)

Types

@Serializable

@SerialName(value = "!Postgres")

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

Functions

open override fun close()

onPartitionAssigned

open suspend override fun onPartitionAssigned(partition: Int, afterToken: ExternalSourceToken?, txIndexer: TxIndexer)