xtdb-core/xtdb.api.log

Package-level declarations

Types

sealed interface DbOp

class InMemoryLog<M>(instantSource: InstantSource, val epoch: Int) : Log<M>

class LocalLog<M>(rootPath: Path, codec: MessageCodec<M>, instantSource: InstantSource, val epoch: Int, val useInstantSourceForNonTx: Boolean, coroutineContext: CoroutineContext = Dispatchers.IO, logFileName: String = "LOG") : Log<M>

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).

class ReadOnlyLog<M>(delegate: Log<M>) : Log<M>

sealed interface ReplicaMessage

sealed interface SourceMessage

class Watchers(latestTxId: TxId, latestSourceMsgId: MessageId, externalSourceToken: ExternalSourceToken? = null)