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

BlockBoundary

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

Constructors

constructor(blockIndex: BlockIndex, latestProcessedMsgId: MessageId, externalSourceToken: ExternalSourceToken? = null, termId: Long = 0)

Properties

val blockIndex: BlockIndex

externalSourceToken

val externalSourceToken: ExternalSourceToken?

latestProcessedMsgId

val latestProcessedMsgId: MessageId

open override val termId: Long

Functions

override fun encode(): ByteArray

open override fun toLogMessage(): ReplicaLogMessage