xtdb-core/xtdb.api.log/ReadOnlyLocalLog

ReadOnlyLocalLog

class ReadOnlyLocalLog<M>(rootPath: Path, codec: MessageCodec<M>, val epoch: Int, coroutineContext: CoroutineContext = Dispatchers.Default, logFileName: String = "LOG") : Log<M>

A read-only version of LocalLog that watches the log file for new messages written by another process (the primary cluster).

Constructors

ReadOnlyLocalLog

constructor(rootPath: Path, codec: MessageCodec<M>, epoch: Int, coroutineContext: CoroutineContext = Dispatchers.Default, logFileName: String = "LOG")

Types

Companion

object Companion

Properties

epoch

open override val epoch: Int

latestSubmittedMsgId

open val latestSubmittedMsgId: MessageId

latestSubmittedOffset

open override val latestSubmittedOffset: LogOffset

Functions

appendMessage

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

appendMessageBlocking

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

open override fun close()

openAtomicProducer

open override fun openAtomicProducer(transactionalId: String): Nothing

openGroupSubscription

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

readLastMessage

open override fun readLastMessage(): M?

readRecords

open override 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

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