xtdb-core/xtdb.api.log/ReplicaMessage/ResolvedTx

ResolvedTx

data class ResolvedTx(val txId: MessageId, val systemTime: Instant, val committed: Boolean, val error: Throwable?, val tableData: Map<String, ByteString>, val dbOp: DbOp? = null, val externalSourceToken: ExternalSourceToken? = null, val srcMsgId: MessageId? = null, val termId: Long, val termSeq: Long? = null) : ReplicaMessage.ProtobufMessage

Constructors

constructor(txId: MessageId, systemTime: Instant, committed: Boolean, error: Throwable?, tableData: Map<String, ByteString>, dbOp: DbOp? = null, externalSourceToken: ExternalSourceToken? = null, srcMsgId: MessageId? = null, termId: Long, termSeq: Long? = null)

Properties

val committed: Boolean

val dbOp: DbOp?

val error: Throwable?

externalSourceToken

val externalSourceToken: ExternalSourceToken?

val srcMsgId: MessageId?

val systemTime: Instant

val tableData: Map<String, ByteString>

open override val termId: Long

open override val termSeq: Long?

val txId: MessageId

Functions

override fun encode(): ByteArray

open override fun toLogMessage(): ReplicaLogMessage

open override fun withTermSeq(termSeq: Long): ReplicaMessage.ResolvedTx

This message at termSeq — stamped by the term's append pump, which alone knows the position.