database/ru.sydis.database/SplitBufferSender

SplitBufferSender

class SplitBufferSender(val broker: MessageBroker<*, *>)

Constructors

SplitBufferSender

constructor(broker: MessageBroker<*, *>)

Types

class OfferResult(dropFirst: Boolean)

PreparedMessage

data class PreparedMessage(val ts: Long, val num: Long, val msg: List<ProtoValue>)

data class RawMessage(val ts: Long, val num: Long, val msg: ByteArray)

Properties

val broker: MessageBroker<*, *>

Functions

fun rawOffer(ts: Long, num: Long, bytes: ByteArray)

reduStateChange

fun reduStateChange(newState: ProtoReduState)

fun startReporting(sectorSize: Long)