SourceMessage

sealed interface SourceMessage

Types

data class AttachDatabase(val dbName: DatabaseName, val config: Database.Config) : SourceMessage.ProtobufMessage

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

data class FlushBlock(val expectedBlockIdx: BlockIndex?) : SourceMessage.ProtobufMessage

data class TriesAdded(val storageVersion: Int, val storageEpoch: StorageEpoch, val tries: List<TrieDetails>) : SourceMessage.ProtobufMessage

data class Tx(val txOps: ByteArray, val systemTime: Instant?, val defaultTz: ZoneId, val user: String?, val userMetadata: ByteArray?, val externalSourceToken: ExternalSourceToken? = null) : SourceMessage.ProtobufMessage

abstract fun encode(): ByteArray