xtdb-core/xtdb.api.log/PartitionLog

PartitionLog

class PartitionLog<M>(log: Log<M>, val partition: Int)

A Log view bound to a single partition: the partition-indexed operations with the index pre-applied, so a per-partition consumer holds its slice of the log without threading the partition through every call.

Deliberately not the whole Log surface — Log.epoch belongs to the shared log, reached through DatabaseLogs, not to a single partition's view.

Constructors

PartitionLog

constructor(log: Log<M>, partition: Int)

Properties

partition

val partition: Int

Functions

appendMessage

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

tailAll

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

withTail

suspend fun <R> withTail(afterMsgId: MessageId, action: suspend (Log.Tail<M>) -> R): R