xtdb-core/xtdb.api.log/LocalLog/Factory

Factory

@SerialName(value = "!Local")

@Serializable

data class Factory @JvmOverloads constructor(val path: Path, var instantSource: InstantSource = InstantSource.system(), var epoch: Int = 0, var useInstantSourceForNonTx: Boolean = false, var coroutineContext: CoroutineContext = Dispatchers.IO) : Log.Factory

Used to set configuration options for a local directory based XTDB Log.

Example usage, as part of a node config:

Xtdb.openNode {
   log = localLog(Path("test-path")) {
     instantSource = InstantSource.system()
     bufferSize = 4096
     pollSleepDuration = Duration.ofMillis(100)
   }
   ...
}

Constructors

constructor(path: Path, instantSource: InstantSource = InstantSource.system(), epoch: Int = 0, useInstantSourceForNonTx: Boolean = false, coroutineContext: CoroutineContext = Dispatchers.IO)

Properties

coroutineContext

@Transient

var coroutineContext: CoroutineContext

@Transient

var instantSource: InstantSource

useInstantSourceForNonTx

var useInstantSourceForNonTx: Boolean

Functions

coroutineContext

fun coroutineContext(coroutineContext: CoroutineContext): LocalLog.Factory

fun epoch(epoch: Int): LocalLog.Factory

fun instantSource(instantSource: InstantSource): LocalLog.Factory

openReadOnlyReplicaLog

open override fun openReadOnlyReplicaLog(remotes: Map<RemoteAlias, Remote>): ReadOnlyLocalLog<ReplicaMessage>

openReadOnlySourceLog

open override fun openReadOnlySourceLog(remotes: Map<RemoteAlias, Remote>): ReadOnlyLocalLog<SourceMessage>

open override fun openReplicaLog(remotes: Map<RemoteAlias, Remote>): LocalLog<ReplicaMessage>

open override fun openSourceLog(remotes: Map<RemoteAlias, Remote>): LocalLog<SourceMessage>

useInstantSourceForNonTx

fun useInstantSourceForNonTx(): LocalLog.Factory

open override fun writeTo(dbConfig: DatabaseConfig.Builder)