xtdb-postgres-source/xtdb.postgres/DirectMirror

DirectMirror

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.

Constructors

DirectMirror

constructor()

Types

Factory

@Serializable

@SerialName(value = "!DirectMirror")

class Factory : PgIndexer.Factory

Functions

open override fun close()

indexTx

open override fun indexTx(tx: PostgresDriver.Transaction, openTx: OpenTx)