The transport's handle on a partition's leader election, driven as a three-step state machine (follower → prepared → leading). See allium/log-processor-lifecycle.allium.

TailSpec

data class TailSpec<M>(val afterMsgId: MessageId, val processor: Log.RecordProcessor<M>)

Properties

epoch

abstract val epoch: Int

latestSubmittedMsgId

open val latestSubmittedMsgId: MessageId

latestSubmittedOffset

abstract val latestSubmittedOffset: LogOffset

Functions

appendMessage

abstract suspend fun appendMessage(message: M): Log.MessageMetadata

appendMessageBlocking

open fun appendMessageBlocking(message: M): Log.MessageMetadata

abstract fun close()

openAtomicProducer

abstract fun openAtomicProducer(transactionalId: String): Log.AtomicProducer<M>

openGroupSubscription

abstract suspend fun openGroupSubscription(listener: Log.SubscriptionListener<M>)

readLastMessage

abstract fun readLastMessage(): M?

readRecords

abstract fun readRecords(fromMsgId: MessageId, toMsgId: MessageId): Sequence<Log.Record<M>>

Reads records in the range [fromMsgId, toMsgId) (start-inclusive, end-exclusive). Returns a lazy sequence of decoded records in offset order. If toMsgId exceeds the latest submitted offset, reads up to the latest available record.

tailAll

abstract suspend fun tailAll(afterMsgId: MessageId, processor: Log.RecordProcessor<M>)