Package-level declarations

Types

The default PgIndexer: mirrors the upstream into XT as-is. A row from public.users lands in the users table; _id is taken from the row, with explicit _valid_from/_valid_to columns honoured when present.

PgIndexer

interface PgIndexer : AutoCloseable

Writes a source PostgresDriver.Transaction into XT via the supplied OpenTx.

PostgresRemote

class PostgresRemote(val hostname: String, val port: Int, val database: String, val username: String, val password: String) : Remote

PostgresSource

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