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

BlockBoundary

data class BlockBoundary(val blockIndex: BlockIndex, val latestProcessedMsgId: MessageId, val externalSourceToken: ExternalSourceToken? = null, val termId: Long, val termSeq: Long? = null) : ReplicaMessage.ProtobufMessage

Constructors

Link copied to clipboard
constructor(blockIndex: BlockIndex, latestProcessedMsgId: MessageId, externalSourceToken: ExternalSourceToken? = null, termId: Long, termSeq: Long? = null)

Properties

Link copied to clipboard
val blockIndex: BlockIndex
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
open override val termId: Long
Link copied to clipboard
open override val termSeq: Long?

Functions

Link copied to clipboard
override fun encode(): ByteArray
Link copied to clipboard
open override fun toLogMessage(): ReplicaLogMessage
Link copied to clipboard
open override fun withTermSeq(termSeq: Long): ReplicaMessage.BlockBoundary

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

Generated by Dokka
© 2026 Copyright