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

BlockBoundary

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

Constructors

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

Properties

val blockIndex: BlockIndex

externalSourceToken

val externalSourceToken: ExternalSourceToken?

latestProcessedMsgId

val latestProcessedMsgId: MessageId

Functions

override fun encode(): ByteArray

open override fun toLogMessage(): ReplicaLogMessage