xtdb-core/xtdb.api.tx

Package-level declarations

Types

interface ExternalSource : AutoCloseable

SPI for streaming transactions into a database from an upstream feed (a CDC source, message log, etc.) instead of XTDB's own DML.

ExternalSourceToken

typealias ExternalSourceToken = ByteArray

Opaque resume marker (e.g. a serialised log offset) that XTDB persists per tx and hands back on resume.

OpenTx

class OpenTx @JvmOverloads constructor(allocator: BufferAllocator, nodeBase: NodeBase, dbStorage: DatabaseStorage, dbState: DatabaseState, val txKey: TransactionKey, val externalSourceToken: ExternalSourceToken?, tracer: Tracer? = null, resolvedTxs: List<ResolvedTx> = emptyList()) : AutoCloseable

The per-transaction write/read handle passed to an external-source writer.

TxIndexer

interface TxIndexer

Per-tx entry point for external sources. The source provides tx metadata + a writer that populates the OpenTx and returns a TxResult indicating success or failure (with optional userMetadata — the source can decide metadata after writing, not before).