ReplicaMessage

Types

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

data class BlockUploaded(val storageVersion: Int, val storageEpoch: StorageEpoch, val blockIndex: BlockIndex, val latestProcessedMsgId: MessageId, val tries: List<TrieDetails>, val externalSourceToken: ExternalSourceToken? = null) : ReplicaMessage.ProtobufMessage

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

data class TriesAdded(val storageVersion: Int, val storageEpoch: StorageEpoch, val tries: List<TrieDetails>, val sourceMsgId: MessageId = 0) : ReplicaMessage.ProtobufMessage

data class TriesDeleted(val tableName: String, val trieKeys: Set<TrieKey>) : ReplicaMessage.ProtobufMessage

abstract fun encode(): ByteArray